Skip to content

Commit

Permalink
Revert "improve mqtt5 tests"
Browse files Browse the repository at this point in the history
This reverts commit 5863980.
  • Loading branch information
xiazhvera committed Sep 7, 2023
1 parent 5863980 commit 1ae1662
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -608,7 +608,7 @@ public void ConnDC_UC6() {
willPacketBuilder.withQOS(QOS.AT_LEAST_ONCE).withPayload("Hello World".getBytes()).withTopic("test/topic");

ConnectPacketBuilder connectBuilder = new ConnectPacketBuilder();
connectBuilder.withClientId("MQTT5 CRT" + UUID.randomUUID().toString());
connectBuilder.withClientId("MQTT5 CRT");
connectBuilder.withKeepAliveIntervalSeconds(1000L);
connectBuilder.withMaximumPacketSizeBytes(1000L);
connectBuilder.withPassword(AWS_TEST_MQTT5_BASIC_AUTH_PASSWORD.getBytes());
Expand Down Expand Up @@ -876,7 +876,7 @@ public void ConnWS_UC6() {
willPacketBuilder.withQOS(QOS.AT_LEAST_ONCE).withPayload("Hello World".getBytes()).withTopic("test/topic");

ConnectPacketBuilder connectBuilder = new ConnectPacketBuilder();
connectBuilder.withClientId("MQTT5 CRT"+UUID.randomUUID().toString());
connectBuilder.withClientId("MQTT5 CRT");
connectBuilder.withKeepAliveIntervalSeconds(1000L);
connectBuilder.withMaximumPacketSizeBytes(1000L);
connectBuilder.withPassword(AWS_TEST_MQTT5_BASIC_AUTH_PASSWORD.getBytes());
Expand Down Expand Up @@ -1984,7 +1984,6 @@ public void Negotiated_Rejoin_Always() {
events.connectSuccessSettings.getRejoinedSession());

client.stop(new DisconnectPacketBuilder().build());
events.stopFuture.get();
}

builder.withSessionBehavior(ClientSessionBehavior.REJOIN_ALWAYS);
Expand Down

0 comments on commit 1ae1662

Please sign in to comment.