Author: rajith
Date: Tue Jun 28 03:03:40 2011
New Revision: 1140413
URL: http://svn.apache.org/viewvc?rev=1140413&view=rev
Log:
QPID-3302 Added a test case to cover "x-amqp-0-10.app-id".
Modified:
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java
Modified:
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java?rev=1140413&r1=1140412&r2=1140413&view=diff
==============================================================================
---
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java
(original)
+++
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java
Tue Jun 28 03:03:40 2011
@@ -169,36 +169,36 @@ public class JMSPropertiesTest extends Q
}
/**
- * 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"));
}
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscr...@qpid.apache.org
