From 44d27acbe15df7da90d87c6d672ea5df95b4794e Mon Sep 17 00:00:00 2001
From: Arnaud Simon <arnaudsimon@apache.org>
Date: Thu, 21 Feb 2008 14:41:51 +0000
Subject: added message releasing when messag listener is set

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@629806 13f79535-47bb-0310-9956-ffa450edef68
---
 .../org/apache/qpid/client/BasicMessageConsumer_0_10.java     | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

(limited to 'qpid/java/client/src')

diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
index 3534bade61..3a9fae1d91 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
@@ -421,7 +421,16 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<Struct[], By
         }
         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()
-- 
cgit v1.2.1