From 42a1f6e78fef4f294f61a58bc4901403dbe1ade5 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Mon, 19 Aug 2013 09:11:40 +0000 Subject: 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 --- .../main/java/org/apache/qpid/server/queue/QueueArgumentsConverter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'qpid/java') 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) { -- cgit v1.2.1