diff options
Diffstat (limited to 'jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/shared')
2 files changed, 2 insertions, 2 deletions
diff --git a/jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/shared/SharedDestinationSessionTestCase.java b/jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/shared/SharedDestinationSessionTestCase.java index 7226fdf8d85..78e79da4b9f 100644 --- a/jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/shared/SharedDestinationSessionTestCase.java +++ b/jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/shared/SharedDestinationSessionTestCase.java @@ -95,7 +95,7 @@ public class SharedDestinationSessionTestCase { @Test public void requireThatSessionCanSendReply() throws InterruptedException { - RemoteClient client = RemoteClient.newInstanceWithInternSlobrok(); + RemoteClient client = RemoteClient.newInstanceWithInternSlobrok(true); MessageQueue queue = new MessageQueue(); DestinationSessionParams params = new DestinationSessionParams().setMessageHandler(queue); SharedDestinationSession session = newDestinationSession(client.slobrokId(), params); diff --git a/jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/shared/SharedIntermediateSessionTestCase.java b/jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/shared/SharedIntermediateSessionTestCase.java index ee3c5c993db..87958415149 100644 --- a/jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/shared/SharedIntermediateSessionTestCase.java +++ b/jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/shared/SharedIntermediateSessionTestCase.java @@ -131,7 +131,7 @@ public class SharedIntermediateSessionTestCase { @Test public void requireThatSessionCanSendReply() throws InterruptedException { - RemoteClient client = RemoteClient.newInstanceWithInternSlobrok(); + RemoteClient client = RemoteClient.newInstanceWithInternSlobrok(true); MessageQueue queue = new MessageQueue(); IntermediateSessionParams params = new IntermediateSessionParams().setMessageHandler(queue); SharedIntermediateSession session = newIntermediateSession(client.slobrokId(), params, true); |