diff options
| author | Alex Rudyy <orudyy@apache.org> | 2013-10-17 16:35:21 +0000 |
|---|---|---|
| committer | Alex Rudyy <orudyy@apache.org> | 2013-10-17 16:35:21 +0000 |
| commit | 3f12636ce00e540e9d075fe70693b4a6e5ee3a4d (patch) | |
| tree | 6423878827feec63a3575c73a87103bf58f52307 /qpid/java/systests | |
| parent | 052b19ceeea8ed1d4716664d7e9e8a10f60e3fd8 (diff) | |
| download | qpid-python-3f12636ce00e540e9d075fe70693b4a6e5ee3a4d.tar.gz | |
QPID-5242: Remove obsolete conversion of queue message grouping attributes into old grouping arguments on queue creation with Virtual Host adapter
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1533142 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/systests')
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/server/queue/MessageGroupQueueTest.java | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/MessageGroupQueueTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/MessageGroupQueueTest.java index 11e1da18b3..d5cee17fa8 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/MessageGroupQueueTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/MessageGroupQueueTest.java @@ -110,10 +110,10 @@ public class MessageGroupQueueTest extends QpidBrokerTestCase private void simpleGroupAssignment(boolean sharedGroups) throws AMQException, JMSException { final Map<String,Object> arguments = new HashMap<String, Object>(); - arguments.put("qpid.group_header_key","group"); + arguments.put(QueueArgumentsConverter.QPID_GROUP_HEADER_KEY,"group"); if(sharedGroups) { - arguments.put("qpid.shared_msg_group","1"); + arguments.put(QueueArgumentsConverter.QPID_SHARED_MSG_GROUP,"1"); } ((AMQSession) producerSession).createQueue(new AMQShortString(QUEUE), true, false, false, arguments); queue = (Queue) producerSession.createQueue("direct://amq.direct/"+QUEUE+"/"+QUEUE+"?durable='false'&autodelete='true'"); @@ -200,10 +200,10 @@ public class MessageGroupQueueTest extends QpidBrokerTestCase private void consumerCloseGroupAssignment(boolean sharedGroups) throws AMQException, JMSException { final Map<String,Object> arguments = new HashMap<String, Object>(); - arguments.put("qpid.group_header_key","group"); + arguments.put(QueueArgumentsConverter.QPID_GROUP_HEADER_KEY,"group"); if(sharedGroups) { - arguments.put("qpid.shared_msg_group","1"); + arguments.put(QueueArgumentsConverter.QPID_SHARED_MSG_GROUP,"1"); } ((AMQSession) producerSession).createQueue(new AMQShortString(QUEUE), true, false, false, arguments); queue = (Queue) producerSession.createQueue("direct://amq.direct/"+QUEUE+"/"+QUEUE+"?durable='false'&autodelete='true'"); @@ -299,10 +299,10 @@ public class MessageGroupQueueTest extends QpidBrokerTestCase private void consumerCloseWithRelease(boolean sharedGroups) throws AMQException, JMSException { final Map<String,Object> arguments = new HashMap<String, Object>(); - arguments.put("qpid.group_header_key","group"); + arguments.put(QueueArgumentsConverter.QPID_GROUP_HEADER_KEY,"group"); if(sharedGroups) { - arguments.put("qpid.shared_msg_group","1"); + arguments.put(QueueArgumentsConverter.QPID_SHARED_MSG_GROUP,"1"); } ((AMQSession) producerSession).createQueue(new AMQShortString(QUEUE), true, false, false, arguments); @@ -391,10 +391,10 @@ public class MessageGroupQueueTest extends QpidBrokerTestCase private void groupAssignmentOnEmpty(boolean sharedGroups) throws AMQException, JMSException { final Map<String,Object> arguments = new HashMap<String, Object>(); - arguments.put("qpid.group_header_key","group"); + arguments.put(QueueArgumentsConverter.QPID_GROUP_HEADER_KEY,"group"); if(sharedGroups) { - arguments.put("qpid.shared_msg_group","1"); + arguments.put(QueueArgumentsConverter.QPID_SHARED_MSG_GROUP,"1"); } ((AMQSession) producerSession).createQueue(new AMQShortString(QUEUE), true, false, false, arguments); |