qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arnaudsi...@apache.org
Subject svn commit: r586461 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
Date Fri, 19 Oct 2007 14:01:32 GMT
Author: arnaudsimon
Date: Fri Oct 19 07:01:31 2007
New Revision: 586461

URL: http://svn.apache.org/viewvc?rev=586461&view=rev
Log:
Changed to handle empty data

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=586461&r1=586460&r2=586461&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
Fri Oct 19 07:01:31 2007
@@ -31,6 +31,7 @@
 import javax.jms.Message;
 import javax.jms.JMSException;
 import java.io.IOException;
+import java.nio.ByteBuffer;
 
 /**
  * This is a 0_10 message producer.
@@ -75,6 +76,10 @@
             if (message.getData() != null)
             {
                 qpidityMessage.appendData(message.getData().buf());
+            }
+            else
+            {
+                   qpidityMessage.appendData(ByteBuffer.allocate(0));
             }
         }
         catch (IOException e)



Mime
View raw message