Author: arnaudsimon
Date: Thu Oct 18 05:32:37 2007
New Revision: 585944
URL: http://svn.apache.org/viewvc?rev=585944&view=rev
Log:
Added original message update
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=585944&r1=585943&r2=585944&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
Thu Oct 18 05:32:37 2007
@@ -66,15 +66,10 @@
{
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 @@
_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
{
