You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2007/10/24 11:23:59 UTC
svn commit: r587827 -
/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
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));