activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1166177 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/Stomp11Test.java
Date Wed, 07 Sep 2011 13:44:33 GMT
Author: tabish
Date: Wed Sep  7 13:44:33 2011
New Revision: 1166177

URL: http://svn.apache.org/viewvc?rev=1166177&view=rev
Log:
add test for: https://issues.apache.org/jira/browse/AMQ-3484

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/Stomp11Test.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/Stomp11Test.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/Stomp11Test.java?rev=1166177&r1=1166176&r2=1166177&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/Stomp11Test.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/Stomp11Test.java
Wed Sep  7 13:44:33 2011
@@ -239,6 +239,34 @@ public class Stomp11Test extends Combina
         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 Combina
         String frame = "DISCONNECT\n" + "\n\n" + Stomp.NULL;
         stompConnection.sendFrame(frame);
     }
-
 }



Mime
View raw message