com.rabbitmq.jms.client.message

Class RMQMapMessage

java.lang.Object

com.rabbitmq.jms.client.RMQMessage

com.rabbitmq.jms.client.message.RMQMapMessage

All Implemented Interfaces:

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

public class RMQMapMessage
extends RMQMessage
implements javax.jms.MapMessage

Implementation of MapMessage 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
RMQMapMessage()

Method Summary

Modifier and Type	Method and Description
void	clearBodyInternal()
protected <T> T	doGetBody(java.lang.Class<T> c)
boolean	getBoolean(java.lang.String name)
byte	getByte(java.lang.String name)
byte[]	getBytes(java.lang.String name)
char	getChar(java.lang.String name)
double	getDouble(java.lang.String name)
float	getFloat(java.lang.String name)
int	getInt(java.lang.String name)
long	getLong(java.lang.String name)
java.util.Enumeration<java.lang.String>	getMapNames()
java.lang.Object	getObject(java.lang.String name)
short	getShort(java.lang.String name)
java.lang.String	getString(java.lang.String name)
boolean	isBodyAssignableTo(java.lang.Class c)
boolean	itemExists(java.lang.String name)
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.MapMessage msg)
void	setBoolean(java.lang.String name, boolean value)
void	setByte(java.lang.String name, byte value)
void	setBytes(java.lang.String name, byte[] value)
void	setBytes(java.lang.String name, byte[] value, int offset, int length)
void	setChar(java.lang.String name, char value)
void	setDouble(java.lang.String name, double value)
void	setFloat(java.lang.String name, float value)
void	setInt(java.lang.String name, int value)
void	setLong(java.lang.String name, long value)
void	setObject(java.lang.String name, java.lang.Object value)
void	setShort(java.lang.String name, short value)
void	setString(java.lang.String name, java.lang.String value)
protected void	writeAmqpBody(java.io.ByteArrayOutputStream out) Invoked when RMQMessage.toAmqpByteArray() is called to create a byte[] from a message.
protected 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

RMQMapMessage

public RMQMapMessage()

Method Detail

getBoolean

public boolean getBoolean(java.lang.String name)
                   throws javax.jms.JMSException

Specified by:

getBoolean in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

getByte

public byte getByte(java.lang.String name)
             throws javax.jms.JMSException

Specified by:

getByte in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

getShort

public short getShort(java.lang.String name)
               throws javax.jms.JMSException

Specified by:

getShort in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

getChar

public char getChar(java.lang.String name)
             throws javax.jms.JMSException

Specified by:

getChar in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

getInt

public int getInt(java.lang.String name)
           throws javax.jms.JMSException

Specified by:

getInt in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

getLong

public long getLong(java.lang.String name)
             throws javax.jms.JMSException

Specified by:

getLong in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

getFloat

public float getFloat(java.lang.String name)
               throws javax.jms.JMSException

Specified by:

getFloat in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

getDouble

public double getDouble(java.lang.String name)
                 throws javax.jms.JMSException

Specified by:

getDouble in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

getString

public java.lang.String getString(java.lang.String name)
                           throws javax.jms.JMSException

Specified by:

getString in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

getBytes

public byte[] getBytes(java.lang.String name)
                throws javax.jms.JMSException

Specified by:

getBytes in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

getObject

public java.lang.Object getObject(java.lang.String name)
                           throws javax.jms.JMSException

Specified by:

getObject in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

getMapNames

public java.util.Enumeration<java.lang.String> getMapNames()
                                                    throws javax.jms.JMSException

Specified by:

getMapNames in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

setBoolean

public void setBoolean(java.lang.String name,
                       boolean value)
                throws javax.jms.JMSException

Specified by:

setBoolean in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

setByte

public void setByte(java.lang.String name,
                    byte value)
             throws javax.jms.JMSException

Specified by:

setByte in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

setShort

public void setShort(java.lang.String name,
                     short value)
              throws javax.jms.JMSException

Specified by:

setShort in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

setChar

public void setChar(java.lang.String name,
                    char value)
             throws javax.jms.JMSException

Specified by:

setChar in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

setInt

public void setInt(java.lang.String name,
                   int value)
            throws javax.jms.JMSException

Specified by:

setInt in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

setLong

public void setLong(java.lang.String name,
                    long value)
             throws javax.jms.JMSException

Specified by:

setLong in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

setFloat

public void setFloat(java.lang.String name,
                     float value)
              throws javax.jms.JMSException

Specified by:

setFloat in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

setDouble

public void setDouble(java.lang.String name,
                      double value)
               throws javax.jms.JMSException

Specified by:

setDouble in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

setString

public void setString(java.lang.String name,
                      java.lang.String value)
               throws javax.jms.JMSException

Specified by:

setString in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

setBytes

public void setBytes(java.lang.String name,
                     byte[] value)
              throws javax.jms.JMSException

Specified by:

setBytes in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

setBytes

public void setBytes(java.lang.String name,
                     byte[] value,
                     int offset,
                     int length)
              throws javax.jms.JMSException

Specified by:

setBytes in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

setObject

public void setObject(java.lang.String name,
                      java.lang.Object value)
               throws javax.jms.JMSException

Specified by:

setObject in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

itemExists

public boolean itemExists(java.lang.String name)
                   throws javax.jms.JMSException

Specified by:

itemExists in interface javax.jms.MapMessage

Throws:

javax.jms.JMSException

clearBodyInternal

public void clearBodyInternal()
                       throws javax.jms.JMSException

Specified by:

clearBodyInternal in class RMQMessage

Throws:

javax.jms.JMSException

writeBody

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

Description copied from class: RMQMessage

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

Description copied from class: RMQMessage

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

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

recreate

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

Throws:

javax.jms.JMSException

isBodyAssignableTo

public boolean isBodyAssignableTo(java.lang.Class c)

Specified by:

isBodyAssignableTo in interface javax.jms.Message

doGetBody

protected <T> T doGetBody(java.lang.Class<T> c)

Specified by:

doGetBody in class RMQMessage