diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2007-01-19 22:54:22 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2007-01-19 22:54:22 +0000 |
| commit | 632083bde7cb6fcd70d68df2339938874f3eadf0 (patch) | |
| tree | cfdff02f1f63b72a77336a30eadb280252d71232 /java/client/src | |
| parent | 9016b88d0519e556975017150019a9b8a037b6d1 (diff) | |
| download | qpid-python-632083bde7cb6fcd70d68df2339938874f3eadf0.tar.gz | |
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
Diffstat (limited to 'java/client/src')
| -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 |