From 632083bde7cb6fcd70d68df2339938874f3eadf0 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Fri, 19 Jan 2007 22:54:22 +0000 Subject: Put the exchange name into destination git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497991 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/qpid/client/BasicMessageProducer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'java') 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 -- cgit v1.2.1