Author: rgodfrey
Date: Mon Aug 19 09:11:40 2013
New Revision: 1515323
URL: http://svn.apache.org/r1515323
Log:
QPID-5081 : [Java Broker] Refactor Queue Creation - allow integer argument for
qpid.shared_msg_group
Modified:
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueArgumentsConverter.java
Modified:
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueArgumentsConverter.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueArgumentsConverter.java?rev=1515323&r1=1515322&r2=1515323&view=diff
==============================================================================
---
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueArgumentsConverter.java
(original)
+++
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueArgumentsConverter.java
Mon Aug 19 09:11:40 2013
@@ -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)
{
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
