aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus/src/test/java/com/yahoo/messagebus/routing
diff options
context:
space:
mode:
authorArne H Juul <arnej@yahooinc.com>2021-12-16 08:29:14 +0000
committerArne H Juul <arnej@yahooinc.com>2021-12-16 08:29:14 +0000
commitd3e60400a37aae23002dcdc6bc99c09d5cd27dba (patch)
tree34e2ffa43ef127d48ca9debfb28f4459f2d68f2c /messagebus/src/test/java/com/yahoo/messagebus/routing
parent06964c7d6bda6f93894fa87253c705f836759421 (diff)
improve testserver start/stop logging slightly
Diffstat (limited to 'messagebus/src/test/java/com/yahoo/messagebus/routing')
-rw-r--r--messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingTestCase.java6
1 files changed, 2 insertions, 4 deletions
diff --git a/messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingTestCase.java b/messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingTestCase.java
index aec99306ff2..f2c5b26c685 100644
--- a/messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingTestCase.java
+++ b/messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingTestCase.java
@@ -53,15 +53,13 @@ public class RoutingTestCase {
@Before
public void setUp() throws ListenFailedException, UnknownHostException {
slobrok = new Slobrok();
- dstServer = new TestServer(new MessageBusParams().addProtocol(new SimpleProtocol()),
- new RPCNetworkParams().setIdentity(new Identity("dst")).setSlobrokConfigId(
- TestServer.getSlobrokConfig(slobrok)));
+ dstServer = new TestServer("dst", null, slobrok, null);
dstSession = dstServer.mb.createDestinationSession(
new DestinationSessionParams().setName("session").setMessageHandler(new Receptor()));
retryPolicy = new RetryTransientErrorsPolicy();
retryPolicy.setBaseDelay(0);
srcServer = new TestServer(new MessageBusParams().setRetryPolicy(retryPolicy).addProtocol(new SimpleProtocol()),
- new RPCNetworkParams().setSlobrokConfigId(TestServer.getSlobrokConfig(slobrok)));
+ slobrok);
srcSession = srcServer.mb.createSourceSession(
new SourceSessionParams().setTimeout(600.0).setThrottlePolicy(null).setReplyHandler(new Receptor()));
assertTrue(srcServer.waitSlobrok("dst/session", 1));