From ceb6f31cdde10e52f0caa4c4bdd396700a262dee Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Tue, 23 Jan 2007 14:23:25 +0000 Subject: Modified Content to make get methods to be non-consuming through use of light-weight copys. Shortened name of Content type enum. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499030 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/qpid/client/BasicMessageProducer.java | 4 ++-- .../org/apache/qpid/client/handler/MessageTransferMethodHandler.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) (limited to 'java/client') 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 b667eb0242..dba8049657 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 @@ -577,7 +577,7 @@ public class BasicMessageProducer extends Closeable implements org.apache.qpid.j // 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.TypeEnum.INLINE_T, payload); doMessageTransfer(messageHeaders,destination,data,message,deliveryMode,priority,timeToLive,immediate); } else { @@ -598,7 +598,7 @@ public class BasicMessageProducer extends Closeable implements org.apache.qpid.j doMessageOpen(referenceId); // Message.Transfer - Content data = new Content(Content.ContentTypeEnum.CONTENT_TYPE_REFERENCE,referenceId.getBytes()); + Content data = new Content(Content.TypeEnum.REF_T, referenceId.getBytes()); doMessageTransfer(messageHeaders,destination,data,message,deliveryMode,priority,timeToLive,immediate); //Message.Append diff --git a/java/client/src/main/java/org/apache/qpid/client/handler/MessageTransferMethodHandler.java b/java/client/src/main/java/org/apache/qpid/client/handler/MessageTransferMethodHandler.java index fa31bc8056..f4e917a943 100644 --- a/java/client/src/main/java/org/apache/qpid/client/handler/MessageTransferMethodHandler.java +++ b/java/client/src/main/java/org/apache/qpid/client/handler/MessageTransferMethodHandler.java @@ -75,7 +75,7 @@ public class MessageTransferMethodHandler implements StateAwareMethodListener msg.contentHeader = messageHeaders; - if(transferBody.getBody().contentType == Content.ContentTypeEnum.CONTENT_TYPE_INLINE) + if(transferBody.getBody().contentType == Content.TypeEnum.INLINE_T) { msg.addContent(transferBody.getBody().getContentAsByteArray()); protocolSession.deliverMessageToAMQSession(evt.getChannelId(), msg); -- cgit v1.2.1