diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2012-02-28 22:57:11 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2012-02-28 22:57:11 +0000 |
| commit | 1d992108034268f8c0490810daa62e29075bbb69 (patch) | |
| tree | 23a21821bb006769e51cac9076239c814595ca59 /qpid/java/systests/src | |
| parent | 8f94378bb9b5155b7c3f7b12164f7cbc81b12734 (diff) | |
| download | qpid-python-1d992108034268f8c0490810daa62e29075bbb69.tar.gz | |
QPID-3605 : [Java Broker] Durable subscriber with no-local true receives messages on re-connection
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1294884 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/systests/src')
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/server/persistent/NoLocalAfterRecoveryTest.java | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/persistent/NoLocalAfterRecoveryTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/persistent/NoLocalAfterRecoveryTest.java index 2e259191aa..d5cbaaa203 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/persistent/NoLocalAfterRecoveryTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/persistent/NoLocalAfterRecoveryTest.java @@ -89,12 +89,11 @@ public class NoLocalAfterRecoveryTest extends QpidBrokerTestCase createDurableSubscriber(topic2, MY_TOPIC_SUBSCRIPTION_NAME + "-NoLocal", null, true); - // The NO-local subscriber should now get ALL the messages - // as they are being consumed on a different connection to - // the one that they were published on. + // The NO-local subscriber should not get any messages received = receiveMessage(noLocalSubscriber2, SEND_COUNT); session2.commit(); - assertEquals("No Local Subscriber Received messages", SEND_COUNT, received.size()); + assertEquals("No Local Subscriber Received messages", 0, received.size()); + } protected List<Message> receiveMessage(MessageConsumer messageConsumer, |