diff options
| author | Arnaud Simon <arnaudsimon@apache.org> | 2007-10-18 12:32:37 +0000 |
|---|---|---|
| committer | Arnaud Simon <arnaudsimon@apache.org> | 2007-10-18 12:32:37 +0000 |
| commit | 5fab67a9881d5113a1b1bb0cd66235b430885618 (patch) | |
| tree | bdf08663676cf31633721bf859316ecd23415857 /java/client/src | |
| parent | 54db50ef611dcfd18a883f58ed8d1089d6ecea9b (diff) | |
| download | qpid-python-5fab67a9881d5113a1b1bb0cd66235b430885618.tar.gz | |
Added original message update
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@585944 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java index e43fef5c94..a50c34ba51 100644 --- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java +++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java @@ -66,15 +66,10 @@ public class BasicMessageProducer_0_10 extends BasicMessageProducer { message.prepareForSending(); org.apache.qpidity.api.Message qpidityMessage = new ByteBufferMessage(); - // set the payload - if(_logger.isDebugEnabled()) { _logger.debug("Message Props: " + message.toString()); } - - //System.out.println("Message Props" + message.toString()); - try { if (message.getData() != null) @@ -143,6 +138,14 @@ public class BasicMessageProducer_0_10 extends BasicMessageProducer _logger.debug(key + "=" + qpidityMessage.getMessageProperties().getApplicationHeaders().get(key)); } } + if(_logger.isDebugEnabled() ) + { + _logger.debug("Updating original message"); + } + origMessage.setJMSPriority(qpidityMessage.getDeliveryProperties().getPriority()); + origMessage.setJMSTimestamp(qpidityMessage.getDeliveryProperties().getTimestamp()); + origMessage.setJMSExpiration(qpidityMessage.getDeliveryProperties().getExpiration()); + origMessage.setJMSMessageID(message.getJMSMessageID()); // send the message try { |