summaryrefslogtreecommitdiff
path: root/java
diff options
context:
space:
mode:
authorArnaud Simon <arnaudsimon@apache.org>2007-10-19 14:01:31 +0000
committerArnaud Simon <arnaudsimon@apache.org>2007-10-19 14:01:31 +0000
commit5ba7bf8e827c0279cb6bedc4ff022bf22085e8f8 (patch)
treee40da9ff04791ad315ff8b82bb7a945928c2104b /java
parent82b63bf62dd63797b71a329038ae443bfeb2474c (diff)
downloadqpid-python-5ba7bf8e827c0279cb6bedc4ff022bf22085e8f8.tar.gz
Changed to handle empty data
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@586461 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java5
1 files changed, 5 insertions, 0 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 a50c34ba51..440282c85e 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
@@ -31,6 +31,7 @@ import org.apache.qpidity.transport.ReplyTo;
import javax.jms.Message;
import javax.jms.JMSException;
import java.io.IOException;
+import java.nio.ByteBuffer;
/**
* This is a 0_10 message producer.
@@ -76,6 +77,10 @@ public class BasicMessageProducer_0_10 extends BasicMessageProducer
{
qpidityMessage.appendData(message.getData().buf());
}
+ else
+ {
+ qpidityMessage.appendData(ByteBuffer.allocate(0));
+ }
}
catch (IOException e)
{