public class AmqpJmsTextMessageFacade extends AmqpJmsMessageFacade implements JmsTextMessageFacade
connection, message
Constructor and Description |
---|
AmqpJmsTextMessageFacade(AmqpConnection connection)
Create a new AMQP Message facade ready for sending.
|
AmqpJmsTextMessageFacade(AmqpConsumer consumer,
org.apache.qpid.proton.message.Message message,
Charset charset)
Creates a new Facade around an incoming AMQP Message for dispatch to the
JMS Consumer instance.
|
Modifier and Type | Method and Description |
---|---|
void |
clearBody()
Clears the contents of this Message.
|
AmqpJmsTextMessageFacade |
copy()
Create a new instance and perform a deep copy of this object's
contents.
|
byte |
getJmsMsgType() |
String |
getText()
Returns the String payload of the Message or null if none set.
|
void |
setText(String value)
Sets the new String payload of the wrapped message, or clears the old value
if the given value is null.
|
applicationPropertyExists, clearProperties, copyInto, getAmqpMessage, getAmqpTimeToLiveOverride, getApplicationProperty, getApplicationPropertyNames, getConnection, getContentType, getCorrelationId, getCorrelationIdBytes, getDeliveryCount, getDestination, getExpiration, getGroupId, getGroupSequence, getMessageId, getPriority, getProperty, getPropertyNames, getProviderMessageIdObject, getRedeliveryCount, getReplyTo, getReplyToGroupId, getTimestamp, getType, getUserId, getUserIdBytes, hasAmqpTimeToLiveOverride, isPersistent, isRedelivered, onDispatch, onSend, propertyExists, setAmqpTimeToLiveOverride, setApplicationProperty, setContentType, setCorrelationId, setCorrelationIdBytes, setDeliveryCount, setDestination, setExpiration, setGroupId, setGroupSequence, setMessageId, setPersistent, setPriority, setProperty, setProviderMessageIdObject, setRedelivered, setRedeliveryCount, setReplyTo, setReplyToGroupId, setTimestamp, setType, setUserId, setUserIdBytes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
clearProperties, getCorrelationId, getCorrelationIdBytes, getDeliveryCount, getDestination, getExpiration, getGroupId, getGroupSequence, getMessageId, getPriority, getProperty, getPropertyNames, getProviderMessageIdObject, getRedeliveryCount, getReplyTo, getTimestamp, getType, getUserId, getUserIdBytes, isPersistent, isRedelivered, onDispatch, onSend, propertyExists, setCorrelationId, setCorrelationIdBytes, setDeliveryCount, setDestination, setExpiration, setGroupId, setGroupSequence, setMessageId, setPersistent, setPriority, setProperty, setProviderMessageIdObject, setRedelivered, setRedeliveryCount, setReplyTo, setTimestamp, setType, setUserId, setUserIdBytes
public AmqpJmsTextMessageFacade(AmqpConnection connection)
connection
- the AmqpConnection that under which this facade was created.public AmqpJmsTextMessageFacade(AmqpConsumer consumer, org.apache.qpid.proton.message.Message message, Charset charset)
consumer
- the consumer that received this message.message
- the incoming Message instance that is being wrapped.charset
- the character set to use when decoding the text when the body is a Data sectionpublic byte getJmsMsgType()
getJmsMsgType
in class AmqpJmsMessageFacade
public AmqpJmsTextMessageFacade copy() throws javax.jms.JMSException
JmsMessageFacade
copy
in interface JmsMessageFacade
copy
in interface JmsTextMessageFacade
copy
in class AmqpJmsMessageFacade
javax.jms.JMSException
- if an error occurs while copying the message.public String getText() throws javax.jms.JMSException
JmsTextMessageFacade
getText
in interface JmsTextMessageFacade
javax.jms.JMSException
- if an error occurs while decoding text payload.public void setText(String value)
JmsTextMessageFacade
setText
in interface JmsTextMessageFacade
value
- the new String payload, or null to clear the contents.public void clearBody()
JmsMessageFacade
clearBody
in interface JmsMessageFacade
clearBody
in class AmqpJmsMessageFacade
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.