From c3962f80e6ff711ed0bced74b42198a4f5118519 Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Tue, 28 Jun 2011 03:03:40 +0000 Subject: QPID-3302 Added a test case to cover "x-amqp-0-10.app-id". git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1140413 13f79535-47bb-0310-9956-ffa450edef68 --- .../qpid/test/unit/message/JMSPropertiesTest.java | 28 +++++++++++----------- 1 file changed, 14 insertions(+), 14 deletions(-) diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java index 8caeaa55c0..5721bcf4e3 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java @@ -169,36 +169,36 @@ public class JMSPropertiesTest extends QpidBrokerTestCase } /** - * Test Goal : test if the message properties can be retrieved properly with out an error - * and also test if unsupported properties are filtered out. See QPID-2930. + * Test Goal : Test if custom message properties can be set and retrieved properly with out an error. + * Also test if unsupported properties are filtered out. See QPID-2930. */ - public void testGetPropertyNames() throws Exception + public void testApplicationProperties() throws Exception { Connection con = getConnection("guest", "guest"); Session ssn = (AMQSession) con.createSession(false, Session.CLIENT_ACKNOWLEDGE); con.start(); - + Topic topic = ssn.createTopic("test"); MessageConsumer consumer = ssn.createConsumer(topic); MessageProducer prod = ssn.createProducer(topic); Message m = ssn.createMessage(); m.setObjectProperty("x-amqp-0-10.routing-key", "routing-key".getBytes()); - m.setObjectProperty("routing-key", "routing-key"); + m.setObjectProperty("x-amqp-0-10.app-id", "my-app-id"); prod.send(m); - + Message msg = consumer.receive(1000); assertNotNull(msg); - + Enumeration enu = msg.getPropertyNames(); Map map = new HashMap(); - while (enu.hasMoreElements()) - { - String name = enu.nextElement(); - String value = msg.getStringProperty(name); + while (enu.hasMoreElements()) + { + String name = enu.nextElement(); + String value = msg.getStringProperty(name); map.put(name, value); - } - + } + assertFalse("Property 'x-amqp-0-10.routing-key' should have been filtered out",map.containsKey("x-amqp-0-10.routing-key")); - assertTrue("Property routing-key should be present",map.containsKey("routing-key")); + assertEquals("Property x-amqp-0-10.app-id should be present","my-app-id",msg.getStringProperty("x-amqp-0-10.app-id")); } } -- cgit v1.2.1