diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2008-08-15 08:21:01 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2008-08-15 08:21:01 +0000 |
| commit | 5078b6a047bd00c43212ed27331b6e1831d762a9 (patch) | |
| tree | e94be9db73aa41dcadc41666828fd6e926fd2446 /java/client | |
| parent | 6c621183826057d728d7bf2056338f599c200bd9 (diff) | |
| download | qpid-python-5078b6a047bd00c43212ed27331b6e1831d762a9.tar.gz | |
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
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java | 2 |
1 files changed, 1 insertions, 1 deletions
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(); } } |