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));