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)