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 {