From 2f0ef2e6706830fcadcb804621c81bb96d790aaa Mon Sep 17 00:00:00 2001 From: "Timothy A. Bish" Date: Sat, 14 Apr 2012 20:25:00 +0000 Subject: [PATCH] Additional test to show that https://issues.apache.org/jira/browse/AMQ-3802 is a non-issue. git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1326200 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/activemq/transport/stomp/StompTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java b/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java index a8d67c1e09..bc03c9a488 100644 --- a/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java @@ -1418,7 +1418,7 @@ public class StompTest extends CombinationTestSupport { 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 CombinationTestSupport { Thread.sleep(400); } catch (InterruptedException e){} assertEquals(view.getDurableTopicSubscribers().length, 0); + assertEquals(view.getInactiveDurableTopicSubscribers().length, 0); } public void testMessageIdHeader() throws Exception {