summaryrefslogtreecommitdiff
path: root/java/client
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2008-08-15 08:42:15 +0000
committerRafael H. Schloming <rhs@apache.org>2008-08-15 08:42:15 +0000
commit5d7b36c4e5bacd6a0843f03797cd230aad7a929c (patch)
tree4b5845ce8a2ba57d9d91dcef1bd3e4e8f897fa5b /java/client
parentb6a376a4797e4988cdae48e0e5395a9b1f4e9f85 (diff)
downloadqpid-python-5d7b36c4e5bacd6a0843f03797cd230aad7a929c.tar.gz
updated qpid.0-10/java to match trunk/qpid/java@686172
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-10@686175 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client')
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java2
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();
}
}