diff options
author | Jon Bratseth <bratseth@gmail.com> | 2022-09-14 13:25:50 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@gmail.com> | 2022-09-14 13:25:50 +0200 |
commit | 78c9bfbe44faa52006e268bd829d83b2d907dbf3 (patch) | |
tree | 16aa34516009643c9199ca2c68947f8627726b70 /messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingContextTestCase.java | |
parent | dda637d7693328ad2f246e88d13d1d2293c59ae8 (diff) |
No functional changes
Diffstat (limited to 'messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingContextTestCase.java')
-rwxr-xr-x | messagebus/src/test/java/com/yahoo/messagebus/routing/RoutingContextTestCase.java | 9 |
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()); } } |