diff options
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); |