qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arnaudsi...@apache.org
Subject svn commit: r587827 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
Date Wed, 24 Oct 2007 09:23:59 GMT
Author: arnaudsimon
Date: Wed Oct 24 02:23:59 2007
New Revision: 587827

URL: http://svn.apache.org/viewvc?rev=587827&view=rev
Log:
Removed JMS_QPID_DESTTYPE, note that this property is not used by 0_10 but JMS provider properties
must be removed from the delivered headers.

Modified:
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java?rev=587827&r1=587826&r2=587827&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
Wed Oct 24 02:23:59 2007
@@ -133,11 +133,11 @@
             qpidityMessage.getMessageProperties()
                     .setReplyTo(new ReplyTo(dest.getExchangeName().toString(), dest.getRoutingKey().toString()));
         }
-         //JMS_QPID_DESTTYPE   is always set but useles so this is a temporary fix
         if (contentHeaderProperties.getHeaders() != null)
         {
+             //JMS_QPID_DESTTYPE   is always set but useles so this is a temporary fix
+            contentHeaderProperties.getHeaders().remove(CustomJMSXProperty.JMS_QPID_DESTTYPE.getShortStringName());
 
             qpidityMessage.getMessageProperties().setApplicationHeaders(FiledTableSupport.convertToMap(contentHeaderProperties.getHeaders()));
-
             for(String key:qpidityMessage.getMessageProperties().getApplicationHeaders().keySet())
             {
                 _logger.debug(key + "=" + qpidityMessage.getMessageProperties().getApplicationHeaders().get(key));



Mime
View raw message