Author: ritchiem
Date: Wed Mar 12 03:40:01 2008
New Revision: 636273
URL: http://svn.apache.org/viewvc?rev=636273&view=rev
Log:
QPID-845 : Reinserted ':' to JMSMessageID.
Modified:
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
incubator/qpid/branches/M2.1/java/client/src/test/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java
Modified:
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java?rev=636273&r1=636272&r2=636273&view=diff
==============================================================================
---
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
(original)
+++
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
Wed Mar 12 03:40:01 2008
@@ -121,7 +121,7 @@
if (getContentHeaderProperties().getMessageIdAsString() == null)
{
StringBuilder b = new StringBuilder(39);
- b.append("ID");
+ b.append("ID:");
b.append(UUID.randomUUID());
getContentHeaderProperties().setMessageId(b.toString());
}
Modified:
incubator/qpid/branches/M2.1/java/client/src/test/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/client/src/test/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java?rev=636273&r1=636272&r2=636273&view=diff
==============================================================================
---
incubator/qpid/branches/M2.1/java/client/src/test/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java
(original)
+++
incubator/qpid/branches/M2.1/java/client/src/test/java/org/apache/qpid/test/unit/message/JMSPropertiesTest.java
Wed Mar 12 03:40:01 2008
@@ -101,6 +101,7 @@
// assertEquals("JMS Delivery Mode
mismatch",sentMsg.getJMSDeliveryMode(),rm.getJMSDeliveryMode());
assertEquals("JMS Type mismatch", sentMsg.getJMSType(),
rm.getJMSType());
assertEquals("JMS Reply To mismatch", sentMsg.getJMSReplyTo(),
rm.getJMSReplyTo());
+ assertTrue("JMSMessageID Does not start ID:",
rm.getJMSMessageID().startsWith("ID:"));
con.close();
}