You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2008/02/21 15:39:37 UTC

svn commit: r629802 - /incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java

Author: arnaudsimon
Date: Thu Feb 21 06:39:37 2008
New Revision: 629802

URL: http://svn.apache.org/viewvc?rev=629802&view=rev
Log:
added consumer2.close as messages may be delivered to this not used consumer

Modified:
    incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java

Modified: incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java?rev=629802&r1=629801&r2=629802&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java (original)
+++ incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java Thu Feb 21 06:39:37 2008
@@ -254,6 +254,7 @@
         {
             try
             {
+                 _consumer2.close();
                 _consumer1.setMessageListener(new MessageListener()
                 {
                     public void onMessage(Message message)