Author: arnaudsimon
Date: Thu Feb 21 06:41:51 2008
New Revision: 629806
URL: http://svn.apache.org/viewvc?rev=629806&view=rev
Log:
added message releasing when messag listener is set
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java?rev=629806&r1=629805&r2=629806&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
Thu Feb 21 06:41:51 2008
@@ -421,7 +421,16 @@
}
else
{
- //TODO: empty the list of sync messages.
+ if(! _synchronousQueue.isEmpty())
+ {
+ Iterator messages=_synchronousQueue.iterator();
+ while (messages.hasNext())
+ {
+ AbstractJMSMessage message=(AbstractJMSMessage)
messages.next();
+ messages.remove();
+ _session.rejectMessage(message, true);
+ }
+ }
if (_connection.started())
{
_0_10session.getQpidSession()
