Author: rajith
Date: Fri Dec 15 14:59:31 2006
New Revision: 487704
URL: http://svn.apache.org/viewvc?view=rev&rev=487704
Log:
This contains a fix for QPID-200
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java?view=diff&rev=487704&r1=487703&r2=487704
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
Fri Dec 15 14:59:31 2006
@@ -460,8 +460,9 @@
}
}
- private void postDeliver(AbstractJMSMessage msg)
+ private void postDeliver(AbstractJMSMessage msg) throws JMSException
{
+ msg.setJMSDestination(_destination);
switch (_acknowledgeMode)
{
case Session.DUPS_OK_ACKNOWLEDGE:
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java?view=diff&rev=487704&r1=487703&r2=487704
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
Fri Dec 15 14:59:31 2006
@@ -52,7 +52,8 @@
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 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
