diff options
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java index 335fd2252d..9c30b59b83 100644 --- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java +++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java @@ -355,10 +355,10 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<Struct[], By return result; } - protected void preApplicationProcessing(AbstractJMSMessage jmsMsg) throws JMSException + void preDeliver(AbstractJMSMessage msg) { _messageCounter.decrementAndGet(); - super.preApplicationProcessing(jmsMsg); + super.preDeliver(msg); } public void setMessageListener(final MessageListener messageListener) throws JMSException @@ -409,6 +409,10 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<Struct[], By { o = _synchronousQueue.take(); } + else + { + System.out.println("null"); + } } } else |