summaryrefslogtreecommitdiff
path: root/qpid/java/broker
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2013-08-19 09:11:40 +0000
committerRobert Godfrey <rgodfrey@apache.org>2013-08-19 09:11:40 +0000
commit42a1f6e78fef4f294f61a58bc4901403dbe1ade5 (patch)
tree85a5637c86a61cedc5493f008553818080aa2c0f /qpid/java/broker
parent01cd3bd0acf60c139893ec5544e7575d64bd094d (diff)
downloadqpid-python-42a1f6e78fef4f294f61a58bc4901403dbe1ade5.tar.gz
QPID-5081 : [Java Broker] Refactor Queue Creation - allow integer argument for qpid.shared_msg_group
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1515323 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker')
-rw-r--r--qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueArgumentsConverter.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueArgumentsConverter.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueArgumentsConverter.java
index f5bee850c2..d4b0c66351 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueArgumentsConverter.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueArgumentsConverter.java
@@ -116,7 +116,7 @@ public class QueueArgumentsConverter
if(wireArguments.containsKey(QPID_SHARED_MSG_GROUP))
{
modelArguments.put(Queue.MESSAGE_GROUP_SHARED_GROUPS,
- SimpleAMQQueue.SHARED_MSG_GROUP_ARG_VALUE.equals(wireArguments.get(QPID_SHARED_MSG_GROUP)));
+ SimpleAMQQueue.SHARED_MSG_GROUP_ARG_VALUE.equals(String.valueOf(wireArguments.get(QPID_SHARED_MSG_GROUP))));
}
if(wireArguments.get(X_QPID_DLQ_ENABLED) != null)
{