Author: aidan
Date: Mon Feb 18 05:47:36 2008
New Revision: 628741
URL: http://svn.apache.org/viewvc?rev=628741&view=rev
Log:
minor fixings
Modified:
incubator/qpid/branches/thegreatmerge/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
incubator/qpid/branches/thegreatmerge/qpid/java/client/src/main/java/org/apache/qpid/client/message/UnprocessedMessage_0_8.java
Modified:
incubator/qpid/branches/thegreatmerge/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/thegreatmerge/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java?rev=628741&r1=628740&r2=628741&view=diff
==============================================================================
---
incubator/qpid/branches/thegreatmerge/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
(original)
+++
incubator/qpid/branches/thegreatmerge/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
Mon Feb 18 05:47:36 2008
@@ -2875,7 +2875,7 @@
//if (message.getDeliverBody() != null)
//{
final BasicMessageConsumer consumer =
- (BasicMessageConsumer)
_consumers.get(message.getConsumerTag());
+ (BasicMessageConsumer) _consumers.get(new
AMQShortString(message.getConsumerTag()));
if ((consumer == null) || consumer.isClosed())
{
Modified:
incubator/qpid/branches/thegreatmerge/qpid/java/client/src/main/java/org/apache/qpid/client/message/UnprocessedMessage_0_8.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/thegreatmerge/qpid/java/client/src/main/java/org/apache/qpid/client/message/UnprocessedMessage_0_8.java?rev=628741&r1=628740&r2=628741&view=diff
==============================================================================
---
incubator/qpid/branches/thegreatmerge/qpid/java/client/src/main/java/org/apache/qpid/client/message/UnprocessedMessage_0_8.java
(original)
+++
incubator/qpid/branches/thegreatmerge/qpid/java/client/src/main/java/org/apache/qpid/client/message/UnprocessedMessage_0_8.java
Mon Feb 18 05:47:36 2008
@@ -60,8 +60,7 @@
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)
