summaryrefslogtreecommitdiff
path: root/qpid
diff options
context:
space:
mode:
authorAidan Skinner <aidan@apache.org>2008-02-18 13:47:36 +0000
committerAidan Skinner <aidan@apache.org>2008-02-18 13:47:36 +0000
commitf4a662a60379b22cafa480c14e381eca1fb91797 (patch)
treedb36049e545e950e7d43adaa6bcf47e550acda98 /qpid
parent172d770e6d956c291027e2c81287cb5a7c1a7e80 (diff)
downloadqpid-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
Diffstat (limited to 'qpid')
-rw-r--r--qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java2
-rw-r--r--qpid/java/client/src/main/java/org/apache/qpid/client/message/UnprocessedMessage_0_8.java3
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)