summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRajith Muditha Attapattu <rajith@apache.org>2011-06-28 03:03:40 +0000
committerRajith Muditha Attapattu <rajith@apache.org>2011-06-28 03:03:40 +0000
commitc3962f80e6ff711ed0bced74b42198a4f5118519 (patch)
tree65cb6227c2994b0e71c8831daa36ecf19c776b67
parent05c37ead555f16c64334c7d351566b57b07c4557 (diff)
downloadqpid-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.java28
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"));
}
}