From bf85418f5bee132a2365b91a307c12db340a08c3 Mon Sep 17 00:00:00 2001 From: Andrew Donald Kennedy Date: Thu, 23 Sep 2010 11:13:56 +0000 Subject: QPID-2879: The 0-10 Java Client is sending null arguments on messageSubscribe Converts the argument Map to a FieldTable and add as an argument to messageSubscribe Patch from git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1000407 13f79535-47bb-0310-9956-ffa450edef68 --- java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'java/client/src') diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java index a2606bfaa8..1d259eacce 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java @@ -595,10 +595,11 @@ public class AMQSession_0_10 extends AMQSession arguments = FieldTable.convertToMap(consumer.getArguments()); getQpidSession().messageSubscribe (queueName.toString(), String.valueOf(tag), getAcknowledgeMode() == NO_ACKNOWLEDGE ? MessageAcceptMode.NONE : MessageAcceptMode.EXPLICIT, - preAcquire ? MessageAcquireMode.PRE_ACQUIRED : MessageAcquireMode.NOT_ACQUIRED, null, 0, null, + preAcquire ? MessageAcquireMode.PRE_ACQUIRED : MessageAcquireMode.NOT_ACQUIRED, null, 0, arguments, consumer.isExclusive() ? Option.EXCLUSIVE : Option.NONE); } catch (JMSException e) -- cgit v1.2.1