diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2007-01-23 14:23:25 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2007-01-23 14:23:25 +0000 |
| commit | ceb6f31cdde10e52f0caa4c4bdd396700a262dee (patch) | |
| tree | c86046c5000567094da60cf09ca2fc122f62429d /java/client/src | |
| parent | 2801b3827c07062ca30b6c246d0c057ebb971777 (diff) | |
| download | qpid-python-ceb6f31cdde10e52f0caa4c4bdd396700a262dee.tar.gz | |
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
Diffstat (limited to 'java/client/src')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java | 4 | ||||
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/handler/MessageTransferMethodHandler.java | 2 |
2 files changed, 3 insertions, 3 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 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); |