qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arnaudsi...@apache.org
Subject svn commit: r585944 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
Date Thu, 18 Oct 2007 12:32:38 GMT
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
         {



Mime
View raw message