diff options
author | Rajith Muditha Attapattu <rajith@apache.org> | 2011-06-28 03:03:40 +0000 |
---|---|---|
committer | Rajith Muditha Attapattu <rajith@apache.org> | 2011-06-28 03:03:40 +0000 |
commit | c3962f80e6ff711ed0bced74b42198a4f5118519 (patch) | |
tree | 65cb6227c2994b0e71c8831daa36ecf19c776b67 | |
parent | 05c37ead555f16c64334c7d351566b57b07c4557 (diff) | |
download | qpid-python-c3962f80e6ff711ed0bced74b42198a4f5118519.tar.gz |
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
-rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java | 28 |
1 files 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<String> enu = msg.getPropertyNames(); Map<String,String> map = new HashMap<String,String>(); - 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")); } } |