You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2007/01/19 23:54:23 UTC
svn commit: r497991 -
/incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java
Author: rhs
Date: Fri Jan 19 14:54:22 2007
New Revision: 497991
URL: http://svn.apache.org/viewvc?view=rev&rev=497991
Log:
Put the exchange name into destination
Modified:
incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java
Modified: incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java?view=diff&rev=497991&r1=497990&r2=497991
==============================================================================
--- incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java (original)
+++ incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java Fri Jan 19 14:54:22 2007
@@ -567,7 +567,7 @@
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 @@
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