diff options
Diffstat (limited to 'qpid/java/client/src/main/java')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 2 | ||||
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/message/UnprocessedMessage_0_8.java | 3 |
2 files changed, 2 insertions, 3 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java index 006649a923..4b7f2fa041 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java @@ -2875,7 +2875,7 @@ public abstract class AMQSession extends Closeable implements Session, QueueSess //if (message.getDeliverBody() != null) //{ final BasicMessageConsumer consumer = - (BasicMessageConsumer) _consumers.get(message.getConsumerTag()); + (BasicMessageConsumer) _consumers.get(new AMQShortString(message.getConsumerTag())); if ((consumer == null) || consumer.isClosed()) { diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/message/UnprocessedMessage_0_8.java b/qpid/java/client/src/main/java/org/apache/qpid/client/message/UnprocessedMessage_0_8.java index d53cc1f986..dc0b526eb7 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/message/UnprocessedMessage_0_8.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/message/UnprocessedMessage_0_8.java @@ -60,8 +60,7 @@ public class UnprocessedMessage_0_8 extends UnprocessedMessage<ContentHeaderBody public UnprocessedMessage_0_8(int channelId, BasicDeliverBody body) { - //FIXME: TGM, SRSLY 4RL - super(channelId, 0, null, body.getExchange(), body.getRoutingKey(), false); + super(channelId, body.getDeliveryTag(), body.getConsumerTag().toString(), body.getExchange(), body.getRoutingKey(), false); } public void receiveBody(ContentBody body) |