diff options
| author | Arnaud Simon <arnaudsimon@apache.org> | 2007-10-24 09:23:59 +0000 |
|---|---|---|
| committer | Arnaud Simon <arnaudsimon@apache.org> | 2007-10-24 09:23:59 +0000 |
| commit | 41381be9bab48b40c7ee8927d101826358e3af18 (patch) | |
| tree | cfb8e581f1619f4c082d97e7c9546dec895fd5bb /qpid/java | |
| parent | 199ce16265a091957fe3ffc597fd1e3245bf1767 (diff) | |
| download | qpid-python-41381be9bab48b40c7ee8927d101826358e3af18.tar.gz | |
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.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@587827 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java index 38de53828a..6033b96c0f 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java @@ -133,11 +133,11 @@ public class BasicMessageProducer_0_10 extends BasicMessageProducer 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)); |