RMQMessage (rabbitmq-jms 2.8.0.RC1 API)

java.lang.Object
- com.rabbitmq.jms.client.RMQMessage

All Implemented Interfaces:

java.lang.Cloneable, javax.jms.Message

Direct Known Subclasses:

RMQBytesMessage, RMQMapMessage, RMQObjectMessage, RMQStreamMessage, RMQTextMessage
```
public abstract class RMQMessage
extends java.lang.Object
implements javax.jms.Message, java.lang.Cloneable
```
Base class for RMQ*Message classes. This is abstract and cannot be instantiated independently.

Field Summary

Fields
Modifier and Type	Field and Description
`protected static int`	`DEFAULT_MESSAGE_BODY_SIZE` When we create a message that has a byte[] as the underlying structure, BytesMessage and StreamMessage, this is the default size.
`protected org.slf4j.Logger`	`logger` Logger shared with derived classes
`protected static java.lang.String`	`MSG_EOF` Error message when we get an EOF exception
`protected static java.lang.String`	`NOT_READABLE` Error message when the message is not readable
`protected static java.lang.String`	`NOT_WRITEABLE` Error message when the message is not writeable
`protected static java.lang.String`	`UNABLE_TO_CAST` Error message used when throwing `MessageFormatException`

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

RMQMessage()
Constructor for auto de-serialization

Constructors
Constructor and Description
`RMQMessage()` Constructor for auto de-serialization

Method Summary

All Methods Static Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`acknowledge()` Although the JavaDoc implies otherwise, this call acknowledges all unacknowledged messages on the message's session.
`void`	`clearBody()`
`protected abstract void`	`clearBodyInternal()`
`void`	`clearProperties()`
`java.lang.Object`	`clone()`
`protected static void`	`copyAttributes(RMQMessage rmqMessage, javax.jms.Message message)` Assign generic attributes.
`protected abstract <T> T`	`doGetBody(java.lang.Class<T> c)`
`static void`	`doNotDeclareReplyToDestination(javax.jms.Message message)` Indicates to not declare a reply-to `RMQDestination`.
`boolean`	`equals(java.lang.Object obj)`
`<T> T`	`getBody(java.lang.Class<T> c)`
`boolean`	`getBooleanProperty(java.lang.String name)`
`byte`	`getByteProperty(java.lang.String name)`
`double`	`getDoubleProperty(java.lang.String name)`
`float`	`getFloatProperty(java.lang.String name)`
`java.lang.String`	`getInternalID()` Returns the unique ID for this message.
`int`	`getIntProperty(java.lang.String name)`
`java.lang.String`	`getJMSCorrelationID()`
`byte[]`	`getJMSCorrelationIDAsBytes()`
`int`	`getJMSDeliveryMode()`
`long`	`getJMSDeliveryTime()`
`javax.jms.Destination`	`getJMSDestination()`
`long`	`getJMSExpiration()`
`java.lang.String`	`getJMSMessageID()`
`int`	`getJMSPriority()`
`boolean`	`getJMSRedelivered()`
`javax.jms.Destination`	`getJMSReplyTo()`
`long`	`getJMSTimestamp()`
`java.lang.String`	`getJMSType()`
`long`	`getLongProperty(java.lang.String name)`
`java.lang.Object`	`getObjectProperty(java.lang.String name)`
`java.util.Enumeration<?>`	`getPropertyNames()`
`long`	`getRabbitDeliveryTag()` returns the delivery tag for this message
`RMQSession`	`getSession()` Returns the session this object belongs to
`short`	`getShortProperty(java.lang.String name)`
`java.lang.String`	`getStringProperty(java.lang.String name)`
`int`	`hashCode()`
`protected boolean`	`isReadonlyBody()` Returns true if this message body is read only This means that message has been received and can not be modified
`protected boolean`	`isReadOnlyProperties()`
`protected void`	`loggerDebugByteArray(java.lang.String format, byte[] buffer, java.lang.Object arg)`
`boolean`	`propertyExists(java.lang.String name)`
`protected abstract 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 abstract void`	`readBody(java.io.ObjectInput inputStream, java.io.ByteArrayInputStream bin)` Invoked when a message is being deserialized to read and decode the message body.
`protected static java.lang.Object`	`readPrimitive(java.io.ObjectInput in)` Utility method to read objects from a stream.
`void`	`setBooleanProperty(java.lang.String name, boolean value)`
`void`	`setByteProperty(java.lang.String name, byte value)`
`void`	`setDoubleProperty(java.lang.String name, double value)`
`void`	`setFloatProperty(java.lang.String name, float value)`
`void`	`setIntProperty(java.lang.String name, int value)`
`void`	`setJMSCorrelationID(java.lang.String correlationID)`
`void`	`setJMSCorrelationIDAsBytes(byte[] correlationID)`
`void`	`setJMSDeliveryMode(int deliveryMode)`
`void`	`setJMSDeliveryTime(long deliveryTime)`
`void`	`setJMSDestination(javax.jms.Destination destination)`
`void`	`setJMSExpiration(long expiration)`
`void`	`setJMSMessageID(java.lang.String id)`
`void`	`setJMSPriority(int priority)`
`void`	`setJMSRedelivered(boolean redelivered)`
`void`	`setJMSReplyTo(javax.jms.Destination replyTo)`
`void`	`setJMSTimestamp(long timestamp)`
`void`	`setJMSType(java.lang.String type)`
`void`	`setLongProperty(java.lang.String name, long value)`
`void`	`setObjectProperty(java.lang.String name, java.lang.Object value)`
`protected void`	`setRabbitDeliveryTag(long rabbitDeliveryTag)` Sets the RabbitMQ delivery tag for this message.
`protected void`	`setReadonly(boolean readonly)` Sets the read only flag on this message
`protected void`	`setReadOnlyBody(boolean readonly)`
`protected void`	`setReadOnlyProperties(boolean readonly)`
`protected void`	`setSession(RMQSession session)` Sets the session this object was received by
`void`	`setShortProperty(java.lang.String name, short value)`
`void`	`setStringProperty(java.lang.String name, java.lang.String value)`
`protected abstract void`	`writeAmqpBody(java.io.ByteArrayOutputStream out)` Invoked when `toAmqpByteArray()` is called to create a byte[] from a message.
`protected abstract void`	`writeBody(java.io.ObjectOutput out, java.io.ByteArrayOutputStream bout)` Invoked when `toByteArray()` is called to create a byte[] from a message.
`protected static void`	`writePrimitive(java.lang.Object s, java.io.ObjectOutput out)` Utility method used to be able to write primitives and objects to a data stream without keeping track of order and type.
`protected static void`	`writePrimitive(java.lang.Object s, java.io.ObjectOutput out, boolean allowSerializable)`

Methods inherited from class java.lang.Object
finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.jms.Message
isBodyAssignableTo

- Field Detail
  - logger
```
protected final org.slf4j.Logger logger
```
    Logger shared with derived classes
  - NOT_READABLE
```
protected static final java.lang.String NOT_READABLE
```
    Error message when the message is not readable
    
    See Also:
    
    Constant Field Values
  - NOT_WRITEABLE
```
protected static final java.lang.String NOT_WRITEABLE
```
    Error message when the message is not writeable
    
    See Also:
    
    Constant Field Values
  - UNABLE_TO_CAST
```
protected static final java.lang.String UNABLE_TO_CAST
```
    Error message used when throwing MessageFormatException
    
    See Also:
    
    Constant Field Values
  - MSG_EOF
```
protected static final java.lang.String MSG_EOF
```
    Error message when we get an EOF exception
    
    See Also:
    
    Constant Field Values
  - DEFAULT_MESSAGE_BODY_SIZE
```
protected static final int DEFAULT_MESSAGE_BODY_SIZE
```
    When we create a message that has a byte[] as the underlying structure, BytesMessage and StreamMessage, this is the default size. Can be changed with a system property.
- Constructor Detail
  - RMQMessage
```
public RMQMessage()
```
    Constructor for auto de-serialization
- Method Detail
  - loggerDebugByteArray
```
protected void loggerDebugByteArray(java.lang.String format,
                                    byte[] buffer,
                                    java.lang.Object arg)
```
  - isReadonlyBody
```
protected boolean isReadonlyBody()
```
    Returns true if this message body is read only This means that message has been received and can not be modified
    
    Returns:
    
    true if the message is read only
  - isReadOnlyProperties
```
protected boolean isReadOnlyProperties()
```
  - setReadonly
```
protected void setReadonly(boolean readonly)
```
    Sets the read only flag on this message
    
    Parameters:
    
    readonly - read only flag value
    
    See Also:
    
    convertMessage(RMQSession, RMQDestination, com.rabbitmq.client.GetResponse, ReceivingContextConsumer)
  - setReadOnlyBody
```
protected void setReadOnlyBody(boolean readonly)
```
  - setReadOnlyProperties
```
protected void setReadOnlyProperties(boolean readonly)
```
  - getRabbitDeliveryTag
```
public long getRabbitDeliveryTag()
```
    returns the delivery tag for this message
    
    Returns:
    
    the delivery tag for this message
  - setRabbitDeliveryTag
```
protected void setRabbitDeliveryTag(long rabbitDeliveryTag)
```
    Sets the RabbitMQ delivery tag for this message.
    
    Parameters:
    
    rabbitDeliveryTag - RabbitMQ delivery tag
    
    See Also:
    
    convertMessage(RMQSession, RMQDestination, com.rabbitmq.client.GetResponse, ReceivingContextConsumer)
  - getSession
```
public RMQSession getSession()
```
    Returns the session this object belongs to
    
    Returns:
    
    the session this object belongs to
  - setSession
```
protected void setSession(RMQSession session)
```
    Sets the session this object was received by
    
    Parameters:
    
    session - the session this object was received by
    
    See Also:
    
    convertMessage(RMQSession, RMQDestination, com.rabbitmq.client.GetResponse, ReceivingContextConsumer), RMQSession.acknowledgeMessage(RMQMessage)
  - getJMSMessageID
```
public java.lang.String getJMSMessageID()
                                 throws javax.jms.JMSException
```
    Specified by:
    
    getJMSMessageID in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setJMSMessageID
```
public void setJMSMessageID(java.lang.String id)
                     throws javax.jms.JMSException
```
    Specified by:
    
    setJMSMessageID in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getJMSTimestamp
```
public long getJMSTimestamp()
                     throws javax.jms.JMSException
```
    Specified by:
    
    getJMSTimestamp in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setJMSTimestamp
```
public void setJMSTimestamp(long timestamp)
                     throws javax.jms.JMSException
```
    Specified by:
    
    setJMSTimestamp in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getJMSCorrelationIDAsBytes
```
public byte[] getJMSCorrelationIDAsBytes()
                                  throws javax.jms.JMSException
```
    Specified by:
    
    getJMSCorrelationIDAsBytes in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setJMSCorrelationIDAsBytes
```
public void setJMSCorrelationIDAsBytes(byte[] correlationID)
                                throws javax.jms.JMSException
```
    Specified by:
    
    setJMSCorrelationIDAsBytes in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setJMSCorrelationID
```
public void setJMSCorrelationID(java.lang.String correlationID)
                         throws javax.jms.JMSException
```
    Specified by:
    
    setJMSCorrelationID in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getJMSCorrelationID
```
public java.lang.String getJMSCorrelationID()
                                     throws javax.jms.JMSException
```
    Specified by:
    
    getJMSCorrelationID in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getJMSReplyTo
```
public javax.jms.Destination getJMSReplyTo()
                                    throws javax.jms.JMSException
```
    Specified by:
    
    getJMSReplyTo in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setJMSReplyTo
```
public void setJMSReplyTo(javax.jms.Destination replyTo)
                   throws javax.jms.JMSException
```
    Specified by:
    
    setJMSReplyTo in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getJMSDestination
```
public javax.jms.Destination getJMSDestination()
                                        throws javax.jms.JMSException
```
    Specified by:
    
    getJMSDestination in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setJMSDestination
```
public void setJMSDestination(javax.jms.Destination destination)
                       throws javax.jms.JMSException
```
    Specified by:
    
    setJMSDestination in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getJMSDeliveryMode
```
public int getJMSDeliveryMode()
                       throws javax.jms.JMSException
```
    Specified by:
    
    getJMSDeliveryMode in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setJMSDeliveryMode
```
public void setJMSDeliveryMode(int deliveryMode)
                        throws javax.jms.JMSException
```
    Specified by:
    
    setJMSDeliveryMode in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getJMSRedelivered
```
public boolean getJMSRedelivered()
                          throws javax.jms.JMSException
```
    Specified by:
    
    getJMSRedelivered in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setJMSRedelivered
```
public void setJMSRedelivered(boolean redelivered)
                       throws javax.jms.JMSException
```
    Specified by:
    
    setJMSRedelivered in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getJMSType
```
public java.lang.String getJMSType()
                            throws javax.jms.JMSException
```
    Specified by:
    
    getJMSType in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setJMSType
```
public void setJMSType(java.lang.String type)
                throws javax.jms.JMSException
```
    Specified by:
    
    setJMSType in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getJMSExpiration
```
public long getJMSExpiration()
                      throws javax.jms.JMSException
```
    Specified by:
    
    getJMSExpiration in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setJMSExpiration
```
public void setJMSExpiration(long expiration)
                      throws javax.jms.JMSException
```
    Specified by:
    
    setJMSExpiration in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getJMSPriority
```
public int getJMSPriority()
                   throws javax.jms.JMSException
```
    Specified by:
    
    getJMSPriority in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setJMSPriority
```
public void setJMSPriority(int priority)
                    throws javax.jms.JMSException
```
    Specified by:
    
    setJMSPriority in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - clearProperties
```
public final void clearProperties()
                           throws javax.jms.JMSException
```
    Specified by:
    
    clearProperties in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - propertyExists
```
public boolean propertyExists(java.lang.String name)
```
    Specified by:
    
    propertyExists in interface javax.jms.Message
  - getBooleanProperty
```
public boolean getBooleanProperty(java.lang.String name)
                           throws javax.jms.JMSException
```
    Specified by:
    
    getBooleanProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getByteProperty
```
public byte getByteProperty(java.lang.String name)
                     throws javax.jms.JMSException
```
    Specified by:
    
    getByteProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getShortProperty
```
public short getShortProperty(java.lang.String name)
                       throws javax.jms.JMSException
```
    Specified by:
    
    getShortProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getIntProperty
```
public int getIntProperty(java.lang.String name)
                   throws javax.jms.JMSException
```
    Specified by:
    
    getIntProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getLongProperty
```
public long getLongProperty(java.lang.String name)
                     throws javax.jms.JMSException
```
    Specified by:
    
    getLongProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getFloatProperty
```
public float getFloatProperty(java.lang.String name)
                       throws javax.jms.JMSException
```
    Specified by:
    
    getFloatProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getDoubleProperty
```
public double getDoubleProperty(java.lang.String name)
                         throws javax.jms.JMSException
```
    Specified by:
    
    getDoubleProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getStringProperty
```
public java.lang.String getStringProperty(java.lang.String name)
                                   throws javax.jms.JMSException
```
    Specified by:
    
    getStringProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getObjectProperty
```
public java.lang.Object getObjectProperty(java.lang.String name)
                                   throws javax.jms.JMSException
```
    Specified by:
    
    getObjectProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getPropertyNames
```
public java.util.Enumeration<?> getPropertyNames()
                                          throws javax.jms.JMSException
```
    Specified by:
    
    getPropertyNames in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setBooleanProperty
```
public void setBooleanProperty(java.lang.String name,
                               boolean value)
                        throws javax.jms.JMSException
```
    Specified by:
    
    setBooleanProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setByteProperty
```
public void setByteProperty(java.lang.String name,
                            byte value)
                     throws javax.jms.JMSException
```
    Specified by:
    
    setByteProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setShortProperty
```
public void setShortProperty(java.lang.String name,
                             short value)
                      throws javax.jms.JMSException
```
    Specified by:
    
    setShortProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setIntProperty
```
public void setIntProperty(java.lang.String name,
                           int value)
                    throws javax.jms.JMSException
```
    Specified by:
    
    setIntProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setLongProperty
```
public void setLongProperty(java.lang.String name,
                            long value)
                     throws javax.jms.JMSException
```
    Specified by:
    
    setLongProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setFloatProperty
```
public void setFloatProperty(java.lang.String name,
                             float value)
                      throws javax.jms.JMSException
```
    Specified by:
    
    setFloatProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setDoubleProperty
```
public void setDoubleProperty(java.lang.String name,
                              double value)
                       throws javax.jms.JMSException
```
    Specified by:
    
    setDoubleProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setStringProperty
```
public void setStringProperty(java.lang.String name,
                              java.lang.String value)
                       throws javax.jms.JMSException
```
    Specified by:
    
    setStringProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setObjectProperty
```
public void setObjectProperty(java.lang.String name,
                              java.lang.Object value)
                       throws javax.jms.JMSException
```
    Specified by:
    
    setObjectProperty in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - acknowledge
```
public void acknowledge()
                 throws javax.jms.JMSException
```
    Although the JavaDoc implies otherwise, this call acknowledges all unacknowledged messages on the message's session.
    The JavaDoc says:
    
    A client may individually acknowledge each message as it is consumed, or it may choose to acknowledge messages as an application-defined group (which is done by calling acknowledge on the last received message of the group, thereby acknowledging all messages consumed by the session.)
    
    ...but there is no way to do either of these things, as is explained by the specification[1].
    
    [1] JMS 1.1 spec Section 11.3.2.2.
    
    Specified by:
    
    acknowledge in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
    
    See Also:
    
    RMQSession.acknowledgeMessage(RMQMessage)
  - clearBody
```
public final void clearBody()
                     throws javax.jms.JMSException
```
    Specified by:
    
    clearBody in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - clearBodyInternal
```
protected abstract void clearBodyInternal()
                                   throws javax.jms.JMSException
```
    Throws:
    
    javax.jms.JMSException
  - writeBody
```
protected abstract void writeBody(java.io.ObjectOutput out,
                                  java.io.ByteArrayOutputStream bout)
                           throws java.io.IOException
```
    Invoked when 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.
    
    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
  - writeAmqpBody
```
protected abstract void writeAmqpBody(java.io.ByteArrayOutputStream out)
                               throws java.io.IOException
```
    Invoked when toAmqpByteArray() is called to create a byte[] from a message. Each subclass must implement this, but ONLY write its specific body.
    
    Parameters:
    
    out - - the output stream to which the message body is written
    
    Throws:
    
    java.io.IOException - if the body can not be written
  - readBody
```
protected abstract 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.
    
    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 abstract 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
    
    Parameters:
    
    barr - - the byte array payload of the AMQP message
  - doNotDeclareReplyToDestination
```
public static void doNotDeclareReplyToDestination(javax.jms.Message message)
                                           throws javax.jms.JMSException
```
    Indicates to not declare a reply-to RMQDestination.
    This is used for inbound messages, when the reply-to destination is supposed to be already created. This avoids trying to create a second time a temporary queue.
    
    Parameters:
    
    message -
    
    Throws:
    
    javax.jms.JMSException
    
    Since:
    
    1.11.0
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class java.lang.Object
  - equals
```
public boolean equals(java.lang.Object obj)
```
    Overrides:
    
    equals in class java.lang.Object
  - getInternalID
```
public java.lang.String getInternalID()
```
    Returns the unique ID for this message. This will return null unless the message has been sent on the wire
    
    Returns:
    
    internal message ID
  - writePrimitive
```
protected static void writePrimitive(java.lang.Object s,
                                     java.io.ObjectOutput out)
                              throws java.io.IOException,
                                     javax.jms.MessageFormatException
```
    Utility method used to be able to write primitives and objects to a data stream without keeping track of order and type.
    This also allows any Object to be written.
    
    The purpose of this method is to optimise the writing of a primitive that is represented as an object by only writing the type and the primitive value to the stream.
    
    Parameters:
    
    s - the primitive to be written
    
    out - the stream to write the primitive to.
    
    Throws:
    
    java.io.IOException - if an I/O error occurs
    
    javax.jms.MessageFormatException - if message cannot be parsed
  - writePrimitive
```
protected static void writePrimitive(java.lang.Object s,
                                     java.io.ObjectOutput out,
                                     boolean allowSerializable)
                              throws java.io.IOException,
                                     javax.jms.MessageFormatException
```
    Throws:
    
    java.io.IOException
    
    javax.jms.MessageFormatException
  - readPrimitive
```
protected static java.lang.Object readPrimitive(java.io.ObjectInput in)
                                         throws java.io.IOException,
                                                java.lang.ClassNotFoundException
```
    Utility method to read objects from a stream. These objects must have been written with the method writePrimitive(Object, ObjectOutput) otherwise deserialization will fail and an IOException will be thrown
    
    Parameters:
    
    in - the stream to read from
    
    Returns:
    
    the Object read
    
    Throws:
    
    java.io.IOException - if an I/O error occurs
    
    java.lang.ClassNotFoundException - if a class of serialized object cannot be found
  - clone
```
public java.lang.Object clone()
                       throws java.lang.CloneNotSupportedException
```
    Overrides:
    
    clone in class java.lang.Object
    
    Throws:
    
    java.lang.CloneNotSupportedException
  - copyAttributes
```
protected static void copyAttributes(RMQMessage rmqMessage,
                                     javax.jms.Message message)
                              throws javax.jms.JMSException
```
    Assign generic attributes.
```
 “rmqMessage = (RMQMessage) message;”
```
    With conversion as appropriate.
    Parameters:
    
    rmqMessage - message filled in with attributes
    
    message - message from which attributes are gained.
    
    Throws:
    
    javax.jms.JMSException - if attributes cannot be copied
  - getJMSDeliveryTime
```
public long getJMSDeliveryTime()
                        throws javax.jms.JMSException
```
    Specified by:
    
    getJMSDeliveryTime in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - setJMSDeliveryTime
```
public void setJMSDeliveryTime(long deliveryTime)
                        throws javax.jms.JMSException
```
    Specified by:
    
    setJMSDeliveryTime in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - getBody
```
public <T> T getBody(java.lang.Class<T> c)
              throws javax.jms.JMSException
```
    Specified by:
    
    getBody in interface javax.jms.Message
    
    Throws:
    
    javax.jms.JMSException
  - doGetBody
```
protected abstract <T> T doGetBody(java.lang.Class<T> c)
                            throws javax.jms.JMSException
```
    Throws:
    
    javax.jms.JMSException

Class RMQMessage

Field Summary

Fields inherited from interface javax.jms.Message

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface javax.jms.Message

Field Detail

logger

NOT_READABLE

NOT_WRITEABLE

UNABLE_TO_CAST

MSG_EOF

DEFAULT_MESSAGE_BODY_SIZE

Constructor Detail

RMQMessage

Method Detail

loggerDebugByteArray

isReadonlyBody

isReadOnlyProperties

setReadonly

setReadOnlyBody

setReadOnlyProperties

getRabbitDeliveryTag

setRabbitDeliveryTag

getSession

setSession

getJMSMessageID

setJMSMessageID

getJMSTimestamp

setJMSTimestamp

getJMSCorrelationIDAsBytes

setJMSCorrelationIDAsBytes

setJMSCorrelationID

getJMSCorrelationID

getJMSReplyTo

setJMSReplyTo

getJMSDestination

setJMSDestination

getJMSDeliveryMode

setJMSDeliveryMode

getJMSRedelivered

setJMSRedelivered

getJMSType

setJMSType

getJMSExpiration

setJMSExpiration

getJMSPriority

setJMSPriority

clearProperties

propertyExists

getBooleanProperty

getByteProperty

getShortProperty

getIntProperty

getLongProperty

getFloatProperty

getDoubleProperty

getStringProperty

getObjectProperty

getPropertyNames

setBooleanProperty

setByteProperty

setShortProperty

setIntProperty

setLongProperty

setFloatProperty

setDoubleProperty

setStringProperty

setObjectProperty

acknowledge

clearBody

clearBodyInternal

writeBody

writeAmqpBody

readBody

readAmqpBody

doNotDeclareReplyToDestination

hashCode

equals