diff options
Diffstat (limited to 'java')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java | 3 | ||||
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java | 7 |
2 files changed, 6 insertions, 4 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 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 |