Skip to content

Commit

Permalink
Fixed error in unit test.
Browse files Browse the repository at this point in the history
Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
  • Loading branch information
Juergen Fickel authored and DerSchwilk committed Sep 21, 2022
1 parent f9c50e9 commit 8fed8c0
Showing 1 changed file with 3 additions and 1 deletion.
Expand Up @@ -107,6 +107,8 @@ public void connectWithoutArgumentWorksAsExpectedIfConfiguredKeepAliveIntervalIs

Mockito.when(subscribingClient.connect(Mockito.any())).thenReturn(CompletableFuture.completedFuture(null));
Mockito.when(publishingClient.connect(Mockito.any())).thenReturn(CompletableFuture.completedFuture(null));
final var sessionExpiryInterval = SessionExpiryInterval.defaultSessionExpiryInterval();
Mockito.when(mqttConfig.getSessionExpiryInterval()).thenReturn(sessionExpiryInterval);
final var receiveMaximum = ReceiveMaximum.of(22_000);
Mockito.when(mqttConfig.getClientReceiveMaximum()).thenReturn(receiveMaximum);
final var cleanSession = true;
Expand All @@ -117,7 +119,7 @@ public void connectWithoutArgumentWorksAsExpectedIfConfiguredKeepAliveIntervalIs
DefaultGenericMqttClient.newInstance(subscribingClient, publishingClient, hiveMqttClientProperties);
final var genericMqttConnect = GenericMqttConnect.newInstance(cleanSession,
keepAliveInterval,
SessionExpiryInterval.defaultSessionExpiryInterval(),
sessionExpiryInterval,
receiveMaximum);

underTest.connect();
Expand Down

0 comments on commit 8fed8c0

Please sign in to comment.