fix compile error

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
eclipse-ditto · Mar 27, 2018 · f68ac72 · f68ac72
1 parent 8f3d94b
commit f68ac72
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...st/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java b/...st/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpConsumerActorTest.java
@@ -60,6 +60,7 @@
 public class AmqpConsumerActorTest {
 
     private static final Config CONFIG = ConfigFactory.load("test");
+    private static final String CONNECTION_ID = "connection";
 
     private static ActorSystem actorSystem;
     private static ActorRef pubSubMediator;
@@ -159,7 +160,7 @@ public void plainStringMappingTest() throws IdConversionException {
             final Props messageMappingProcessorProps =
                     MessageMappingProcessorActor.props(pubSubMediator, targetActorPath, getRef(),
                             AuthorizationContext.newInstance(AuthorizationSubject.newInstance("foo:bar")),
-                            mappingProcessor);
+                            mappingProcessor, CONNECTION_ID);
 
             final ActorRef processor = actorSystem.actorOf(messageMappingProcessorProps,
                     MessageMappingProcessorActor.ACTOR_NAME + "-plainStringMappingTest");
@@ -210,7 +211,7 @@ private ActorRef setupActor(final ActorRef testActor, final List<MappingContext>
         final Props messageMappingProcessorProps =
                 MessageMappingProcessorActor.props(pubSubMediator, pubSubTarget, testActor,
                         AuthorizationContext.newInstance(AuthorizationSubject.newInstance("foo:bar")),
-                        mappingProcessor);
+                        mappingProcessor, CONNECTION_ID);
 
         final DefaultResizer resizer = new DefaultResizer(1, 5);