activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1416515 - /activemq/trunk/activemq-client/src/main/java/org/apache/activemq/command/ActiveMQMessage.java
Date Mon, 03 Dec 2012 13:43:12 GMT
Author: chirino
Date: Mon Dec  3 13:43:12 2012
New Revision: 1416515

URL: http://svn.apache.org/viewvc?rev=1416515&view=rev
Log:
Fixes AMQ-4201 : JMSX* properties not included in the getPropertyNames() enumeration

Modified:
    activemq/trunk/activemq-client/src/main/java/org/apache/activemq/command/ActiveMQMessage.java

Modified: activemq/trunk/activemq-client/src/main/java/org/apache/activemq/command/ActiveMQMessage.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-client/src/main/java/org/apache/activemq/command/ActiveMQMessage.java?rev=1416515&r1=1416514&r2=1416515&view=diff
==============================================================================
--- activemq/trunk/activemq-client/src/main/java/org/apache/activemq/command/ActiveMQMessage.java
(original)
+++ activemq/trunk/activemq-client/src/main/java/org/apache/activemq/command/ActiveMQMessage.java
Mon Dec  3 13:43:12 2012
@@ -311,6 +311,18 @@ public class ActiveMQMessage extends Mes
     public Enumeration getPropertyNames() throws JMSException {
         try {
             Vector<String> result = new Vector<String>(this.getProperties().keySet());
+            if( getRedeliveryCounter()!=0 ) {
+                result.add("JMSXDeliveryCount");
+            }
+            if( getGroupID()!=null ) {
+                result.add("JMSXGroupID");
+            }
+            if( getGroupID()!=null ) {
+                result.add("JMSXGroupSeq");
+            }
+            if( getUserID()!=null ) {
+                result.add("JMSXUserID");
+            }
             return result.elements();
         } catch (IOException e) {
             throw JMSExceptionSupport.create(e);



Mime
View raw message