Class ActiveMQTextMessage
- java.lang.Object
-
- org.apache.activemq.artemis.jms.client.ActiveMQMessage
-
- org.apache.activemq.artemis.jms.client.ActiveMQTextMessage
-
- All Implemented Interfaces:
javax.jms.Message
,javax.jms.TextMessage
- Direct Known Subclasses:
ActiveMQTextCompatibleMessage
public class ActiveMQTextMessage extends ActiveMQMessage implements javax.jms.TextMessage
ActiveMQ Artemis implementation of a JMS TextMessage.
This class was ported from SpyTextMessage in JBossMQ.
-
-
Field Summary
Fields Modifier and Type Field Description static byte
TYPE
-
Fields inherited from class org.apache.activemq.artemis.jms.client.ActiveMQMessage
message, OLD_QUEUE_QUALIFIED_PREFIX, OLD_TEMP_QUEUE_QUALIFED_PREFIX, OLD_TEMP_TOPIC_QUALIFED_PREFIX, OLD_TOPIC_QUALIFIED_PREFIX, propertiesReadOnly, readOnly, replyTo
-
-
Constructor Summary
Constructors Constructor Description ActiveMQTextMessage(javax.jms.TextMessage foreign, ClientSession session)
A copy constructor for non-ActiveMQ Artemis JMS TextMessages.ActiveMQTextMessage(ClientMessage message, ClientSession session)
ActiveMQTextMessage(ClientSession session)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
clearBody()
void
doBeforeReceive()
protected <T> T
getBodyInternal(java.lang.Class<T> c)
java.lang.String
getText()
byte
getType()
boolean
isBodyAssignableTo(java.lang.Class c)
void
setText(java.lang.String text)
-
Methods inherited from class org.apache.activemq.artemis.jms.client.ActiveMQMessage
acknowledge, checkBuffer, checkPrefix, checkPrefixStr, checkRead, checkWrite, clearProperties, coreCompositeTypeToJMSCompositeType, coreMaptoJMSMap, createMessage, createMessage, doBeforeSend, getBody, getBooleanProperty, getByteProperty, getCoreMessage, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDeliveryTime, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, hasNoBody, prefixOf, propertyExists, resetMessageID, saveToOutputStream, setBooleanProperty, setByteProperty, setClientAcknowledge, setDoubleProperty, setFloatProperty, setIndividualAcknowledge, setInputStream, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDeliveryTime, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setOutputStream, setShortProperty, setStringProperty, toString, waitCompletionOnStream
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface javax.jms.Message
acknowledge, clearProperties, getBody, getBooleanProperty, getByteProperty, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDeliveryTime, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, propertyExists, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDeliveryTime, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setShortProperty, setStringProperty
-
-
-
-
Field Detail
-
TYPE
public static final byte TYPE
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
ActiveMQTextMessage
public ActiveMQTextMessage(ClientSession session)
-
ActiveMQTextMessage
public ActiveMQTextMessage(ClientMessage message, ClientSession session)
-
ActiveMQTextMessage
public ActiveMQTextMessage(javax.jms.TextMessage foreign, ClientSession session) throws javax.jms.JMSException
A copy constructor for non-ActiveMQ Artemis JMS TextMessages.- Throws:
javax.jms.JMSException
-
-
Method Detail
-
getType
public byte getType()
- Overrides:
getType
in classActiveMQMessage
-
setText
public void setText(java.lang.String text) throws javax.jms.JMSException
- Specified by:
setText
in interfacejavax.jms.TextMessage
- Throws:
javax.jms.JMSException
-
getText
public java.lang.String getText()
- Specified by:
getText
in interfacejavax.jms.TextMessage
-
clearBody
public void clearBody() throws javax.jms.JMSException
- Specified by:
clearBody
in interfacejavax.jms.Message
- Overrides:
clearBody
in classActiveMQMessage
- Throws:
javax.jms.JMSException
-
doBeforeReceive
public void doBeforeReceive() throws org.apache.activemq.artemis.api.core.ActiveMQException
- Overrides:
doBeforeReceive
in classActiveMQMessage
- Throws:
org.apache.activemq.artemis.api.core.ActiveMQException
-
getBodyInternal
protected <T> T getBodyInternal(java.lang.Class<T> c)
- Overrides:
getBodyInternal
in classActiveMQMessage
-
isBodyAssignableTo
public boolean isBodyAssignableTo(java.lang.Class c)
- Specified by:
isBodyAssignableTo
in interfacejavax.jms.Message
- Overrides:
isBodyAssignableTo
in classActiveMQMessage
-
-