diff options
| author | Aidan Skinner <aidan@apache.org> | 2008-02-18 13:47:36 +0000 |
|---|---|---|
| committer | Aidan Skinner <aidan@apache.org> | 2008-02-18 13:47:36 +0000 |
| commit | f4a662a60379b22cafa480c14e381eca1fb91797 (patch) | |
| tree | db36049e545e950e7d43adaa6bcf47e550acda98 | |
| parent | 172d770e6d956c291027e2c81287cb5a7c1a7e80 (diff) | |
| download | qpid-python-f4a662a60379b22cafa480c14e381eca1fb91797.tar.gz | |
minor fixings
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/thegreatmerge@628741 13f79535-47bb-0310-9956-ffa450edef68
| -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) |