From acde68e3abda44e2a972683c81086f3d9537f79c Mon Sep 17 00:00:00 2001 From: "Timothy A. Bish" Date: Wed, 7 Sep 2011 13:44:33 +0000 Subject: [PATCH] add test for: https://issues.apache.org/jira/browse/AMQ-3484 git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1166177 13f79535-47bb-0310-9956-ffa450edef68 --- .../activemq/transport/stomp/Stomp11Test.java | 29 ++++++++++++++++++- 1 file changed, 28 insertions(+), 1 deletion(-) diff --git a/activemq-core/src/test/java/org/apache/activemq/transport/stomp/Stomp11Test.java b/activemq-core/src/test/java/org/apache/activemq/transport/stomp/Stomp11Test.java index ece20984fb..966a1572d5 100644 --- a/activemq-core/src/test/java/org/apache/activemq/transport/stomp/Stomp11Test.java +++ b/activemq-core/src/test/java/org/apache/activemq/transport/stomp/Stomp11Test.java @@ -239,6 +239,34 @@ public class Stomp11Test extends CombinationTestSupport { assertTrue("Broker did close idle connection in time.", (endTime - startTime) >= 1000); } + public void testSendAfterMissingHeartbeat() throws Exception { + + String connectFrame = "STOMP\n" + "login: system\n" + + "passcode: manager\n" + + "accept-version:1.1\n" + + "heart-beat:1000,0\n" + + "host:localhost\n" + + "\n" + Stomp.NULL; + + stompConnection.sendFrame(connectFrame); + String f = stompConnection.receiveFrame(); + assertTrue(f.startsWith("CONNECTED")); + assertTrue(f.indexOf("version:1.1") >= 0); + assertTrue(f.indexOf("heart-beat:") >= 0); + assertTrue(f.indexOf("session:") >= 0); + LOG.debug("Broker sent: " + f); + + Thread.sleep(5000); + + try { + String message = "SEND\n" + "destination:/queue/" + getQueueName() + "\n\n" + "Hello World" + Stomp.NULL; + stompConnection.sendFrame(message); + fail("SEND frame has been accepted after missing heart beat"); + } catch (Exception ex) { + System.out.println(ex.getMessage()); + } + } + public void testRejectInvalidHeartbeats1() throws Exception { String connectFrame = "STOMP\n" + @@ -542,5 +570,4 @@ public class Stomp11Test extends CombinationTestSupport { String frame = "DISCONNECT\n" + "\n\n" + Stomp.NULL; stompConnection.sendFrame(frame); } - }