Skip to content

Commit

Permalink
Removed unnecessary stubbing.
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 committed Jun 22, 2022
1 parent 0715c57 commit 2f3859b
Showing 1 changed file with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,6 @@
import org.eclipse.ditto.connectivity.model.signals.commands.exceptions.ConnectionFailedException;
import org.eclipse.ditto.connectivity.model.signals.commands.modify.CloseConnection;
import org.eclipse.ditto.connectivity.model.signals.commands.modify.OpenConnection;
import org.eclipse.ditto.connectivity.model.signals.commands.modify.TestConnection;
import org.eclipse.ditto.connectivity.model.signals.commands.query.RetrieveConnectionMetrics;
import org.eclipse.ditto.connectivity.model.signals.commands.query.RetrieveConnectionMetricsResponse;
import org.eclipse.ditto.connectivity.service.messaging.AbstractBaseClientActorTest;
Expand All @@ -58,7 +57,6 @@
import org.eclipse.ditto.connectivity.service.messaging.mqtt.hivemq.client.GenericMqttClient;
import org.eclipse.ditto.connectivity.service.messaging.mqtt.hivemq.client.GenericMqttClientFactory;
import org.eclipse.ditto.connectivity.service.messaging.mqtt.hivemq.client.GenericMqttPublishResult;
import org.eclipse.ditto.connectivity.service.messaging.mqtt.hivemq.client.MqttClientConnectException;
import org.eclipse.ditto.connectivity.service.messaging.mqtt.hivemq.client.MqttSubscribeException;
import org.eclipse.ditto.connectivity.service.messaging.mqtt.hivemq.message.publish.GenericMqttPublish;
import org.eclipse.ditto.connectivity.service.messaging.mqtt.hivemq.message.subscribe.GenericMqttSubAck;
Expand Down Expand Up @@ -160,7 +158,6 @@ public void before() {

private void enableGenericMqttClientMethodStubbing() {
Mockito.when(genericMqttClient.connect()).thenReturn(CompletableFuture.completedFuture(null));
Mockito.when(genericMqttClient.connect(Mockito.any())).thenReturn(CompletableFuture.completedFuture(null));
Mockito.when(genericMqttClient.disconnect()).thenReturn(CompletableFuture.completedFuture(null));
Mockito.when(genericMqttClient.subscribe(Mockito.any()))
.thenReturn(Single.just(Mockito.mock(GenericMqttSubAck.class)));
Expand Down

0 comments on commit 2f3859b

Please sign in to comment.