diff options
Diffstat (limited to 'messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java')
-rwxr-xr-x | messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java | 50 |
1 files changed, 0 insertions, 50 deletions
diff --git a/messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java b/messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java index a8a1fc33284..ff9fc099923 100755 --- a/messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java +++ b/messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java @@ -99,56 +99,6 @@ public class ChokeTestCase { assertEquals(0, dstServer.mb.getPendingCount()); } - @Test - @SuppressWarnings("deprecation") - void testMaxSize() { - int size = createMessage("msg").getApproxSize(); - int max = size * 10; - dstServer.mb.setMaxPendingSize(max); - List<Message> lst = new ArrayList<>(); - for (int i = 0; i < max * 2; i += size) { - if (i < max) { - assertEquals(i, dstServer.mb.getPendingSize()); - } else { - assertEquals(max, dstServer.mb.getPendingSize()); - } - assertTrue(srcSession.send(createMessage("msg"), Route.parse("dst/session")).isAccepted()); - if (i < max) { - Message msg = ((Receptor) dstSession.getMessageHandler()).getMessage(60); - assertNotNull(msg); - lst.add(msg); - } else { - Reply reply = ((Receptor) srcSession.getReplyHandler()).getReply(60); - assertNotNull(reply); - assertEquals(1, reply.getNumErrors()); - assertEquals(ErrorCode.SESSION_BUSY, reply.getError(0).getCode()); - } - } - for (int i = 0; i < 5; ++i) { - Message msg = lst.remove(0); - dstSession.acknowledge(msg); - - Reply reply = ((Receptor) srcSession.getReplyHandler()).getReply(60); - assertNotNull(reply); - assertFalse(reply.hasErrors()); - assertNotNull(msg = reply.getMessage()); - assertTrue(srcSession.send(msg, Route.parse("dst/session")).isAccepted()); - - assertNotNull(msg = ((Receptor) dstSession.getMessageHandler()).getMessage(60)); - lst.add(msg); - } - while (!lst.isEmpty()) { - assertEquals(size * lst.size(), dstServer.mb.getPendingSize()); - Message msg = lst.remove(0); - dstSession.acknowledge(msg); - - Reply reply = ((Receptor) srcSession.getReplyHandler()).getReply(60); - assertNotNull(reply); - assertFalse(reply.hasErrors()); - } - assertEquals(0, dstServer.mb.getPendingSize()); - } - private static Message createMessage(String msg) { Message ret = new SimpleMessage(msg); ret.getTrace().setLevel(9); |