activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1326200 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
Date Sat, 14 Apr 2012 20:25:00 GMT
Author: tabish
Date: Sat Apr 14 20:25:00 2012
New Revision: 1326200

URL: http://svn.apache.org/viewvc?rev=1326200&view=rev
Log:
Additional test to show that https://issues.apache.org/jira/browse/AMQ-3802 is a non-issue.

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

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java?rev=1326200&r1=1326199&r2=1326200&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
Sat Apr 14 20:25:00 2012
@@ -1418,7 +1418,7 @@ public class StompTest extends Combinati
         assertTrue(frame.startsWith("CONNECTED"));
 
         // unsubscribe
-        frame = "UNSUBSCRIBE\n" + "destination:/topic/" + getQueueName() + "\n" + "ack:auto\nactivemq.subscriptionName:test\n\n"
+ Stomp.NULL;
+        frame = "UNSUBSCRIBE\n" + "destination:/topic/" + getQueueName() + "\n" + "activemq.subscriptionName:test\n\n"
+ Stomp.NULL;
         stompConnection.sendFrame(frame);
         frame = "DISCONNECT\n" + "\n\n" + Stomp.NULL;
         stompConnection.sendFrame(frame);
@@ -1426,6 +1426,7 @@ public class StompTest extends Combinati
             Thread.sleep(400);
         } catch (InterruptedException e){}
         assertEquals(view.getDurableTopicSubscribers().length, 0);
+        assertEquals(view.getInactiveDurableTopicSubscribers().length, 0);
     }
 
     public void testMessageIdHeader() throws Exception {



Mime
View raw message