From 2801b3827c07062ca30b6c246d0c057ebb971777 Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Mon, 22 Jan 2007 21:12:45 +0000 Subject: Synchronized the toString method in the Content class Removed commented code from the BasicMessageProducer git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@498804 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/qpid/client/BasicMessageProducer.java | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) (limited to 'java/client/src/main') 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 9267d9127c..b667eb0242 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 @@ -564,10 +564,21 @@ public class BasicMessageProducer extends Closeable implements org.apache.qpid.j int size = (payload != null) ? payload.limit() : 0; final long framePayloadMax = _session.getAMQConnection().getMaximumFrameSize(); + if(_logger.isDebugEnabled()){ + _logger.debug("framePayloadMax " + framePayloadMax); + _logger.debug("size " + size); + _logger.debug("payload capacity" + payload.capacity()); + _logger.debug("payload limit" + payload.limit()); + _logger.debug("payload remaining" + payload.remaining()); + _logger.debug("payload position" + payload.position()); + } + 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); + + Content data = new Content(Content.ContentTypeEnum.CONTENT_TYPE_INLINE,payload); + doMessageTransfer(messageHeaders,destination,data,message,deliveryMode,priority,timeToLive,immediate); } else { // Reference message case -- cgit v1.2.1