diff options
-rwxr-xr-x | documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyTestCase.java | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyTestCase.java b/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyTestCase.java index 4c41edb4dd3..07456870977 100755 --- a/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyTestCase.java +++ b/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyTestCase.java @@ -150,6 +150,7 @@ public class PolicyTestCase { setupExternPolicy(frame, slobrok, "foo/bar"); frame.assertSelect(null); slobrok.stop(); + frame.destroy(); } @Test @@ -367,6 +368,9 @@ public class PolicyTestCase { assertNotNull(barFrame.getReceptor().getReply(TIMEOUT)); assertNotNull(fooFrame.getReceptor().getReply(TIMEOUT)); + + fooFrame.destroy(); + barFrame.destroy(); } @Test @@ -391,6 +395,7 @@ public class PolicyTestCase { assertNotNull(reply); assertEquals(DocumentProtocol.REPLY_GETDOCUMENT, reply.getType()); assertEquals(123456L, ((GetDocumentReply)reply).getLastModified()); + frame.destroy(); } private String getDocumentRouteSelectorRawConfig() { @@ -413,6 +418,7 @@ public class PolicyTestCase { frame.setMessage(createRemove("id:ns:other::1")); frame.assertSelect(Arrays.asList("other-route")); + frame.destroy(); } @Test @@ -424,6 +430,7 @@ public class PolicyTestCase { frame.setMessage(createGet("id:ns:other::1")); frame.assertSelect(Arrays.asList("other-route")); + frame.destroy(); } private PolicyTestFrame createFrameWithTwoRoutes() { @@ -543,6 +550,8 @@ public class PolicyTestCase { assertNotNull(barFrame.getReceptor().getReply(TIMEOUT)); assertNotNull(fooFrame.getReceptor().getReply(TIMEOUT)); + fooFrame.destroy(); + barFrame.destroy(); } @Test @@ -659,6 +668,7 @@ public class PolicyTestCase { frame.setHop(new HopSpec("test", "[LoadBalancer:cluster=docproc/cluster.default;session=chain.default]")); assertSelect(frame, 1, Arrays.asList(frame.getNetwork().getConnectionSpec() + "/chain.default")); + frame.destroy(); } @Test @@ -727,6 +737,8 @@ public class PolicyTestCase { assertNotNull(barFrame.getReceptor().getReply(TIMEOUT)); assertNotNull(fooFrame.getReceptor().getReply(TIMEOUT)); + fooFrame.destroy(); + barFrame.destroy(); } /** |