QPID-2418: revert changes to testResubscribeWithChangedSelector()

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@929979 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 1 insertions, 11 deletions

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",