fix AmqpConsumerActorTest

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
eclipse-ditto · Sep 8, 2021 · 8561078 · 8561078
1 parent 2440292
commit 8561078
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/...est/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConsumerActorTest.java b/...est/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConsumerActorTest.java
@@ -122,6 +122,9 @@ protected Props getConsumerActorProps(final Sink<Object, NotUsed> inboundMapping
     private Props getConsumerActorProps(final MessageConsumer messageConsumer,
             final ActorRef jmsActor, final String address, final Sink<Object, NotUsed> inboundMappingSink,
             final PayloadMapping payloadMapping) {
+        final ConnectivityStatusResolver statusResolver = mock(ConnectivityStatusResolver.class);
+        when(statusResolver.resolve(any(Exception.class))).thenReturn(ConnectivityStatus.MISCONFIGURED);
+
         final ConsumerData mockConsumerData =
                 consumerData(address, messageConsumer, ConnectivityModelFactory.newSourceBuilder()
                         .authorizationContext(TestConstants.Authorization.AUTHORIZATION_CONTEXT)
@@ -134,7 +137,7 @@ private Props getConsumerActorProps(final MessageConsumer messageConsumer,
                                 .build())
                         .build());
         return AmqpConsumerActor.props(CONNECTION, mockConsumerData, inboundMappingSink,
-                jmsActor, mock(ConnectivityStatusResolver.class));
+                jmsActor, statusResolver);
     }
 
     @Override
@@ -429,7 +432,7 @@ public void closedMessageConsumerIsRecreatedAfterBackoffAndResourceStatusIsUpdat
                 // signal closed consumer to consumer actor
                 underTest.tell(ConsumerClosedStatusReport.get(messageConsumer,
                         new ProviderSecurityException(errorMessage)), getRef());
-                verify(messageConsumer).close();
+                verify(messageConsumer, Mockito.timeout(100)).close();
 
                 // verify the actual state ist reflected in the source resource status
                 verifyResourceStatus(underTest, errorMessage, ConnectivityStatus.MISCONFIGURED);