aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingContextTestCase.java
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@gmail.com>2022-09-14 13:25:50 +0200
committerJon Bratseth <bratseth@gmail.com>2022-09-14 13:25:50 +0200
commit78c9bfbe44faa52006e268bd829d83b2d907dbf3 (patch)
tree16aa34516009643c9199ca2c68947f8627726b70 /messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingContextTestCase.java
parentdda637d7693328ad2f246e88d13d1d2293c59ae8 (diff)
No functional changes
Diffstat (limited to 'messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingContextTestCase.java')
-rwxr-xr-xmessagebus/src/test/java/com/yahoo/messagebus/routing/RoutingContextTestCase.java9
1 files changed, 3 insertions, 6 deletions
diff --git a/messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingContextTestCase.java b/messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingContextTestCase.java
index 42a6b244508..b8aa6db8d8a 100755
--- a/messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingContextTestCase.java
+++ b/messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingContextTestCase.java
@@ -96,7 +96,6 @@ public class RoutingContextTestCase {
assertTrue(srcSession.send(createMessage("msg"), "myroute").isAccepted());
Reply reply = ((Receptor) srcSession.getReplyHandler()).getReply(TIMEOUT_SECS);
assertNotNull(reply);
- System.out.println(reply.getTrace());
assertFalse(reply.hasErrors());
}
}
@@ -104,8 +103,8 @@ public class RoutingContextTestCase {
@Test
void testRecipientsRemain() {
SimpleProtocol protocol = new SimpleProtocol();
- protocol.addPolicyFactory("First", new CustomPolicyFactory(true, Arrays.asList("foo/bar"), Arrays.asList("foo/[Second]")));
- protocol.addPolicyFactory("Second", new CustomPolicyFactory(false, Arrays.asList("foo/bar"), Arrays.asList("foo/bar")));
+ protocol.addPolicyFactory("First", new CustomPolicyFactory(true, List.of("foo/bar"), List.of("foo/[Second]")));
+ protocol.addPolicyFactory("Second", new CustomPolicyFactory(false, List.of("foo/bar"), List.of("foo/bar")));
srcServer.mb.putProtocol(protocol);
srcServer.setupRouting(new RoutingTableSpec(SimpleProtocol.NAME)
.addRoute(new RouteSpec("myroute").addHop("myhop"))
@@ -115,7 +114,6 @@ public class RoutingContextTestCase {
assertTrue(srcSession.send(createMessage("msg"), "myroute").isAccepted());
Reply reply = ((Receptor) srcSession.getReplyHandler()).getReply(TIMEOUT_SECS);
assertNotNull(reply);
- System.out.println(reply.getTrace());
assertFalse(reply.hasErrors());
}
}
@@ -129,7 +127,7 @@ public class RoutingContextTestCase {
void testConstRoute() {
SimpleProtocol protocol = new SimpleProtocol();
protocol.addPolicyFactory("DocumentRouteSelector",
- new CustomPolicyFactory(true, Arrays.asList("dst"), Arrays.asList("dst")));
+ new CustomPolicyFactory(true, List.of("dst"), List.of("dst")));
srcServer.mb.putProtocol(protocol);
srcServer.setupRouting(new RoutingTableSpec(SimpleProtocol.NAME)
.addRoute(new RouteSpec("default").addHop("indexing"))
@@ -142,7 +140,6 @@ public class RoutingContextTestCase {
dstSession.acknowledge(msg);
Reply reply = ((Receptor) srcSession.getReplyHandler()).getReply(TIMEOUT_SECS);
assertNotNull(reply);
- System.out.println(reply.getTrace());
assertFalse(reply.hasErrors());
}
}