From 5078b6a047bd00c43212ed27331b6e1831d762a9 Mon Sep 17 00:00:00 2001
From: "Rafael H. Schloming" <rhs@apache.org>
Date: Fri, 15 Aug 2008 08:21:01 +0000
Subject: QPID-1245: use notifyMessage rather than onMessage in
 setMessageListener so that messages from the synchronous queue actually get
 acked

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@686172 13f79535-47bb-0310-9956-ffa450edef68
---
 .../src/main/java/org/apache/qpid/client/BasicMessageConsumer.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'java/client')

diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
index 01bb68c23e..dfd228370c 100644
--- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
+++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
@@ -280,7 +280,7 @@ public abstract class BasicMessageConsumer<U> extends Closeable implements Messa
                     Object o = _synchronousQueue.poll();
                     while (o != null)
                     {
-                        messageListener.onMessage((Message) o);
+                        notifyMessage((AbstractJMSMessage) o);
                         o = _synchronousQueue.poll();
                     }
                 }
-- 
cgit v1.2.1