com.rabbitmq.jms.client.message

Class RMQTextMessage

java.lang.Object

com.rabbitmq.jms.client.RMQMessage

com.rabbitmq.jms.client.message.RMQTextMessage

All Implemented Interfaces:

java.lang.Cloneable, javax.jms.Message, javax.jms.TextMessage

public class RMQTextMessage
extends RMQMessage
implements javax.jms.TextMessage

Implements TextMessage interface.

Field Summary

Fields inherited from class com.rabbitmq.jms.client.RMQMessage

DEFAULT_MESSAGE_BODY_SIZE, logger, MSG_EOF, NOT_READABLE, NOT_WRITEABLE, UNABLE_TO_CAST

Fields inherited from interface javax.jms.Message

DEFAULT_DELIVERY_DELAY, DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE

Constructor Summary

Constructors

Constructor and Description
RMQTextMessage()

Method Summary

Modifier and Type	Method and Description
protected void	clearBodyInternal()
protected <T> T	doGetBody(java.lang.Class<T> c)
java.lang.String	getText()
boolean	isBodyAssignableTo(java.lang.Class c)
protected void	readAmqpBody(byte[] barr) Invoked when an AMQP message is being transformed into a RMQMessage The implementing class should only read its body by this method
protected void	readBody(java.io.ObjectInput inputStream, java.io.ByteArrayInputStream bin) Invoked when a message is being deserialized to read and decode the message body.
static RMQMessage	recreate(javax.jms.TextMessage msg)
void	setText(java.lang.String string)
protected void	writeAmqpBody(java.io.ByteArrayOutputStream out) Invoked when RMQMessage.toAmqpByteArray() is called to create a byte[] from a message.
void	writeBody(java.io.ObjectOutput out, java.io.ByteArrayOutputStream bout) Invoked when RMQMessage.toByteArray() is called to create a byte[] from a message.

Methods inherited from class com.rabbitmq.jms.client.RMQMessage

acknowledge, clearBody, clearProperties, clone, copyAttributes, doNotDeclareReplyToDestination, equals, getBody, getBooleanProperty, getByteProperty, getDoubleProperty, getFloatProperty, getInternalID, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDeliveryTime, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getRabbitDeliveryTag, getSession, getShortProperty, getStringProperty, hashCode, isReadonlyBody, isReadOnlyProperties, loggerDebugByteArray, propertyExists, readPrimitive, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDeliveryTime, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setRabbitDeliveryTag, setReadonly, setReadOnlyBody, setReadOnlyProperties, setSession, setShortProperty, setStringProperty, writePrimitive, writePrimitive

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.jms.Message

acknowledge, clearBody, 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

Constructor Detail

RMQTextMessage

public RMQTextMessage()

Method Detail

setText

public void setText(java.lang.String string)
             throws javax.jms.JMSException

Specified by:

setText in interface javax.jms.TextMessage

Throws:

javax.jms.JMSException

getText

public java.lang.String getText()
                         throws javax.jms.JMSException

Specified by:

getText in interface javax.jms.TextMessage

Throws:

javax.jms.JMSException

clearBodyInternal

protected void clearBodyInternal()

Specified by:

clearBodyInternal in class RMQMessage

writeBody

public void writeBody(java.io.ObjectOutput out,
                      java.io.ByteArrayOutputStream bout)
               throws java.io.IOException

Invoked when RMQMessage.toByteArray() is called to create a byte[] from a message. Each subclass must implement this, but ONLY write its specific body. All the properties defined in Message will be written by the parent class.

Specified by:

writeBody in class RMQMessage

Parameters:

out - - the output stream to which the structured part of message body (scalar types) is written

bout - - the output stream to which the un-structured part of message body (explicit bytes) is written

Throws:

java.io.IOException - if the body can not be written

readBody

protected void readBody(java.io.ObjectInput inputStream,
                        java.io.ByteArrayInputStream bin)
                 throws java.io.IOException,
                        java.lang.ClassNotFoundException

Invoked when a message is being deserialized to read and decode the message body. The implementing class should only read its body from this stream. If any exception is thrown, the message will not have been delivered.

Specified by:

readBody in class RMQMessage

Parameters:

inputStream - - the stream to read its body from

bin - - the underlying byte input stream

Throws:

java.io.IOException - if a read error occurs on the input stream

java.lang.ClassNotFoundException - if the object class cannot be found

readAmqpBody

protected void readAmqpBody(byte[] barr)

Description copied from class: RMQMessage

Invoked when an AMQP message is being transformed into a RMQMessage The implementing class should only read its body by this method

Specified by:

readAmqpBody in class RMQMessage

Parameters:

barr - - the byte array payload of the AMQP message

doGetBody

protected <T> T doGetBody(java.lang.Class<T> c)
                   throws javax.jms.JMSException

Specified by:

doGetBody in class RMQMessage

Throws:

javax.jms.JMSException

writeAmqpBody

protected void writeAmqpBody(java.io.ByteArrayOutputStream out)
                      throws java.io.IOException

Description copied from class: RMQMessage

Invoked when RMQMessage.toAmqpByteArray() is called to create a byte[] from a message. Each subclass must implement this, but ONLY write its specific body.

Specified by:

writeAmqpBody in class RMQMessage

Parameters:

out - - the output stream to which the message body is written

Throws:

java.io.IOException - if the body can not be written

isBodyAssignableTo

public boolean isBodyAssignableTo(java.lang.Class c)

Specified by:

isBodyAssignableTo in interface javax.jms.Message

recreate

public static RMQMessage recreate(javax.jms.TextMessage msg)
                           throws javax.jms.JMSException

Throws:

javax.jms.JMSException