From 5ee1ef64b7a0f207ba0a30602be5082d9d5245bb Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Thu, 1 Apr 2010 14:03:47 +0000 Subject: QPID-2418: revert changes to testResubscribeWithChangedSelector() git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@929979 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/test/unit/topic/DurableSubscriptionTest.java | 12 +----------- 1 file changed, 1 insertion(+), 11 deletions(-) (limited to 'java') diff --git a/java/systests/src/main/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java b/java/systests/src/main/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java index 119949b0d6..5ead443ef1 100644 --- a/java/systests/src/main/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java +++ b/java/systests/src/main/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java @@ -538,9 +538,6 @@ public class DurableSubscriptionTest extends QpidTestCase rMsg = subA.receive(NEGATIVE_RECEIVE_TIMEOUT); assertNull(rMsg); - // Send another 1 matching message and 1 non-matching message - sendMatchingAndNonMatchingMessage(session, producer); - // Disconnect subscriber subA.close(); @@ -548,15 +545,8 @@ public class DurableSubscriptionTest extends QpidTestCase TopicSubscriber subB = session.createDurableSubscriber(topic, "testResubscribeWithChangedSelector","Match = False", false); - //verify no messages are now present as changing selector should have issued - //an unsubscribe and thus deleted the previous backing queue for the subscription. - rMsg = subB.receive(NEGATIVE_RECEIVE_TIMEOUT); - assertNull("Should not have received message as the queue underlying the " + - "subscription should have been cleared/deleted when the selector was changed", rMsg); - - // Check that new messages are received properly + // Check messages are recieved properly sendMatchingAndNonMatchingMessage(session, producer); - rMsg = subB.receive(NEGATIVE_RECEIVE_TIMEOUT); assertNotNull(rMsg); assertEquals("Content was wrong", -- cgit v1.2.1