diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2007-01-22 21:12:45 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2007-01-22 21:12:45 +0000 |
| commit | 2801b3827c07062ca30b6c246d0c057ebb971777 (patch) | |
| tree | 69a99114cf694d98183ed8e8b7516aab51bc2836 /java/client/src/main | |
| parent | abfd652c09f7a267b175d7105ca0b9c1f618e368 (diff) | |
| download | qpid-python-2801b3827c07062ca30b6c246d0c057ebb971777.tar.gz | |
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
Diffstat (limited to 'java/client/src/main')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java | 13 |
1 files changed, 12 insertions, 1 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 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 |