svn commit: r618984 - in /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message: AbstractJMSMessage.java AbstractJMSMessageFactory.java

[arnaudsimon]

Author: arnaudsimon
Date: Wed Feb  6 04:52:19 2008
New Revision: 618984

URL: http://svn.apache.org/viewvc?rev=618984&view=rev
Log:
Byte message were losing their payload see QPI-779

Modified:
    
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
    
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessageFactory.java

Modified: 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java?rev=618984&r1=618983&r2=618984&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java
 Wed Feb  6 04:52:19 2008
@@ -739,4 +739,9 @@
         _consumer = basicMessageConsumer;
     }
 
+    public void receivedFromServer()
+    {
+        _changedData = false;
+    }
+
 }

Modified: 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessageFactory.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessageFactory.java?rev=618984&r1=618983&r2=618984&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessageFactory.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessageFactory.java
 Wed Feb  6 04:52:19 2008
@@ -140,7 +140,9 @@
         props.setType(mprop.getType());
         props.setUserId(mprop.getUserId());
         
props.setHeaders(FiledTableSupport.convertToFieldTable(mprop.getApplicationHeaders()));
        
-        return createMessage(messageNbr, data, exchange, routingKey, props);
+        AbstractJMSMessage message = createMessage(messageNbr, data, exchange, 
routingKey, props);
+        message.receivedFromServer();
+        return message;
     }