diff options
Diffstat (limited to 'qpid/java/systests/src/main/java/org/apache/qpid/server/queue/MessageGroupQueueTest.java')
| -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); |