From e218021f74ac0b85d83f3bbd5183ff457037d143 Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Fri, 15 Dec 2006 22:59:31 +0000 Subject: This contains a fix for QPID-200 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@487704 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/qpid/client/BasicMessageConsumer.java | 3 ++- .../java/org/apache/qpid/client/message/AbstractJMSMessage.java | 7 ++++--- 2 files changed, 6 insertions(+), 4 deletions(-) (limited to 'java/client/src/main') 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 31a2e6bd82..d6118f5560 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 @@ -460,8 +460,9 @@ public class BasicMessageConsumer extends Closeable implements MessageConsumer } } - private void postDeliver(AbstractJMSMessage msg) + private void postDeliver(AbstractJMSMessage msg) throws JMSException { + msg.setJMSDestination(_destination); switch (_acknowledgeMode) { case Session.DUPS_OK_ACKNOWLEDGE: diff --git a/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java b/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java index 978b74e789..ade330b63b 100644 --- a/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java +++ b/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java @@ -52,7 +52,8 @@ public abstract class AbstractJMSMessage extends AMQMessage implements javax.jms protected ByteBuffer _data; private boolean _readableProperties = false; private boolean _readableMessage = false; - + private Destination _destination; + protected AbstractJMSMessage(ByteBuffer data) { super(new BasicContentHeaderProperties()); @@ -176,12 +177,12 @@ public abstract class AbstractJMSMessage extends AMQMessage implements javax.jms public Destination getJMSDestination() throws JMSException { // TODO: implement this once we have sorted out how to figure out the exchange class - throw new JmsNotImplementedException(); + return _destination; } public void setJMSDestination(Destination destination) throws JMSException { - throw new JmsNotImplementedException(); + _destination = destination; } public int getJMSDeliveryMode() throws JMSException -- cgit v1.2.1