diff options
| author | Arnaud Simon <arnaudsimon@apache.org> | 2008-02-21 14:39:37 +0000 |
|---|---|---|
| committer | Arnaud Simon <arnaudsimon@apache.org> | 2008-02-21 14:39:37 +0000 |
| commit | d058b7642442baa0075bcfcc51e2b96a32319841 (patch) | |
| tree | 0b1c18379e62279bdf53412b17c416628fe0e6e0 /qpid/java/client | |
| parent | c6a9fbd3182752b5f2dbc50195576ceb67a96a9f (diff) | |
| download | qpid-python-d058b7642442baa0075bcfcc51e2b96a32319841.tar.gz | |
added consumer2.close as messages may be delivered to this not used consumer
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@629802 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client')
| -rw-r--r-- | qpid/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/qpid/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java b/qpid/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java index 775ab01732..882915fb8f 100644 --- a/qpid/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java +++ b/qpid/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java @@ -254,6 +254,7 @@ public class ResetMessageListenerTest extends QpidTestCase { try { + _consumer2.close(); _consumer1.setMessageListener(new MessageListener() { public void onMessage(Message message) |