diff options
Diffstat (limited to 'java')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java index 505491f9df..9267d9127c 100644 --- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java +++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java @@ -567,7 +567,7 @@ public class BasicMessageProducer extends Closeable implements org.apache.qpid.j if (size < framePayloadMax){ // Inline message case _logger.debug("Inline case, sending data inline with the transfer method"); - Content data = new Content(Content.ContentTypeEnum.CONTENT_TYPE_INLINE,payload.array()); + Content data = new Content(Content.ContentTypeEnum.CONTENT_TYPE_INLINE,payload); doMessageTransfer(messageHeaders,destination,data,message,deliveryMode,priority,timeToLive,immediate); } else { // Reference message case @@ -623,7 +623,7 @@ public class BasicMessageProducer extends Closeable implements org.apache.qpid.j messageHeaders.getContentType(), // String contentType messageHeaders.getCorrelationId(), // String correlationId (short)deliveryMode, // short deliveryMode - messageHeaders.getDestination(), // String destination + destination.getExchangeName(), // String destination destination.getExchangeName(), // String exchange messageHeaders.getExpiration(), // long expiration immediate, // boolean immediate |