org.fusesource.stomp.jms.message

Class StompJmsMessage

java.lang.Object

org.fusesource.stomp.jms.message.StompJmsMessage

All Implemented Interfaces:

javax.jms.Message

Direct Known Subclasses:

StompJmsBytesMessage, StompJmsMapMessage, StompJmsObjectMessage, StompJmsStreamMessage, StompJmsTextMessage

public class StompJmsMessage
extends java.lang.Object
implements javax.jms.Message

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StompJmsMessage.JmsMsgType

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.Callable<java.lang.Void>	acknowledgeCallback
protected StompJmsConnection	connection
protected StompFrame	frame
protected java.util.Map<java.lang.String,java.lang.Object>	properties
protected boolean	readOnlyBody
protected boolean	readOnlyProperties
static java.util.HashSet<org.fusesource.hawtbuf.AsciiBuffer>	REVERSED_HEADER_NAMES
protected org.fusesource.hawtbuf.AsciiBuffer	transactionId

Fields inherited from interface javax.jms.Message

DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE

Constructor Summary

Constructors

Constructor and Description
StompJmsMessage()

Method Summary

Methods

Modifier and Type	Method and Description
void	acknowledge()
protected void	checkReadOnlyBody()
protected void	checkValidObject(java.lang.Object value)
void	clearBody()
void	clearProperties()
StompJmsMessage	copy()
protected void	copy(StompJmsMessage other)
protected static java.lang.String	decodeString(byte[] data)
protected static byte[]	encodeString(java.lang.String data)
boolean	equals(java.lang.Object o)
java.util.concurrent.Callable<java.lang.Void>	getAcknowledgeCallback()
java.util.Enumeration	getAllPropertyNames() return all property names, including standard JMS properties and JMSX properties
boolean	getBooleanProperty(java.lang.String name)
byte	getByteProperty(java.lang.String name)
StompJmsConnection	getConnection()
org.fusesource.hawtbuf.AsciiBuffer	getConsumerId()
org.fusesource.hawtbuf.Buffer	getContent()
double	getDoubleProperty(java.lang.String name)
float	getFloatProperty(java.lang.String name)
StompFrame	getFrame()
protected java.util.Map<org.fusesource.hawtbuf.AsciiBuffer,org.fusesource.hawtbuf.AsciiBuffer>	getHeaderMap()
int	getIntProperty(java.lang.String name)
java.lang.String	getJMSCorrelationID()
byte[]	getJMSCorrelationIDAsBytes()
int	getJMSDeliveryMode()
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)
org.fusesource.hawtbuf.AsciiBuffer	getMessageID()
StompJmsMessage.JmsMsgType	getMsgType()
java.lang.Object	getObjectProperty(java.lang.String name)
java.util.Map<java.lang.String,java.lang.Object>	getProperties()
java.util.Enumeration	getPropertyNames()
int	getRedeliveryCounter()
short	getShortProperty(java.lang.String name)
StompJmsDestination	getStompJmsDestination()
StompJmsDestination	getStompJmsReplyTo()
java.lang.String	getStringProperty(java.lang.String name)
org.fusesource.hawtbuf.AsciiBuffer	getTransactionId()
int	hashCode()
boolean	isPersistent()
boolean	isRedelivered()
protected void	lazyCreateProperties()
void	onSend() Send operation event listener.
boolean	propertyExists(java.lang.String name)
void	removeProperty(java.lang.String name)
void	setAcknowledgeCallback(java.util.concurrent.Callable<java.lang.Void> acknowledgeCallback)
void	setBooleanProperty(java.lang.String name, boolean value)
void	setBooleanProperty(java.lang.String name, boolean value, boolean checkReadOnly)
void	setByteProperty(java.lang.String name, byte value)
void	setConnection(StompJmsConnection connection)
void	setContent(org.fusesource.hawtbuf.Buffer content)
void	setDoubleProperty(java.lang.String name, double value)
void	setFloatProperty(java.lang.String name, float value)
void	setFrame(StompFrame frame)
void	setIntProperty(java.lang.String name, int value)
void	setJMSCorrelationID(java.lang.String correlationId)
void	setJMSCorrelationIDAsBytes(byte[] correlationId)
void	setJMSDeliveryMode(int mode)
void	setJMSDestination(javax.jms.Destination destination)
void	setJMSDestination(StompJmsDestination destination)
void	setJMSExpiration(long expiration)
void	setJMSMessageID(java.lang.String value) Seems to be invalid because the parameter doesn't initialize MessageId instance variables ProducerId and ProducerSequenceId
void	setJMSPriority(int priority)
void	setJMSRedelivered(boolean redelivered)
void	setJMSReplyTo(javax.jms.Destination destination)
void	setJMSReplyTo(StompJmsDestination destination)
void	setJMSTimestamp(long timestamp)
void	setJMSType(java.lang.String type)
void	setLongProperty(java.lang.String name, long value)
void	setMessageID(org.fusesource.hawtbuf.AsciiBuffer value)
void	setObjectProperty(java.lang.String name, java.lang.Object value)
void	setObjectProperty(java.lang.String name, java.lang.Object value, boolean checkReadOnly)
void	setPersistent(boolean value)
void	setProperties(java.util.Map<java.lang.String,java.lang.Object> properties)
void	setProperty(java.lang.String name, java.lang.Object value)
void	setReadOnlyBody(boolean readOnlyBody)
void	setReadOnlyProperties(boolean readOnlyProperties)
void	setRedelivered(boolean redelivered)
void	setRedeliveryCounter(int deliveryCounter)
void	setShortProperty(java.lang.String name, short value)
void	setStringProperty(java.lang.String name, java.lang.String value)
void	setTransactionId(org.fusesource.hawtbuf.AsciiBuffer transactionId)
void	storeContent() serialize the payload

Methods inherited from class java.lang.Object

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

Field Detail

REVERSED_HEADER_NAMES

public static java.util.HashSet<org.fusesource.hawtbuf.AsciiBuffer> REVERSED_HEADER_NAMES

acknowledgeCallback

protected transient java.util.concurrent.Callable<java.lang.Void> acknowledgeCallback

connection

protected transient StompJmsConnection connection

readOnlyBody

protected boolean readOnlyBody

readOnlyProperties

protected boolean readOnlyProperties

properties

protected java.util.Map<java.lang.String,java.lang.Object> properties

transactionId

protected org.fusesource.hawtbuf.AsciiBuffer transactionId

frame

protected StompFrame frame

Constructor Detail

StompJmsMessage

public StompJmsMessage()

Method Detail

copy

public StompJmsMessage copy()
                     throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getMsgType

public StompJmsMessage.JmsMsgType getMsgType()

getFrame

public StompFrame getFrame()

setFrame

public void setFrame(StompFrame frame)

copy

protected void copy(StompJmsMessage other)

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

acknowledge

public void acknowledge()
                 throws javax.jms.JMSException

Specified by:

acknowledge in interface javax.jms.Message

Throws:

javax.jms.JMSException

getContent

public org.fusesource.hawtbuf.Buffer getContent()

setContent

public void setContent(org.fusesource.hawtbuf.Buffer content)

clearBody

public void clearBody()
               throws javax.jms.JMSException

Specified by:

clearBody in interface javax.jms.Message

Throws:

javax.jms.JMSException

setReadOnlyBody

public void setReadOnlyBody(boolean readOnlyBody)

setReadOnlyProperties

public void setReadOnlyProperties(boolean readOnlyProperties)

getMessageID

public org.fusesource.hawtbuf.AsciiBuffer getMessageID()

getJMSMessageID

public java.lang.String getJMSMessageID()

Specified by:

getJMSMessageID in interface javax.jms.Message

setJMSMessageID

public void setJMSMessageID(java.lang.String value)

Seems to be invalid because the parameter doesn't initialize MessageId instance variables ProducerId and ProducerSequenceId

Specified by:

setJMSMessageID in interface javax.jms.Message

Parameters:

value -

Throws:

javax.jms.JMSException

setMessageID

public void setMessageID(org.fusesource.hawtbuf.AsciiBuffer value)

getJMSTimestamp

public long getJMSTimestamp()

Specified by:

getJMSTimestamp in interface javax.jms.Message

setJMSTimestamp

public void setJMSTimestamp(long timestamp)

Specified by:

setJMSTimestamp in interface javax.jms.Message

getJMSCorrelationID

public java.lang.String getJMSCorrelationID()

Specified by:

getJMSCorrelationID in interface javax.jms.Message

setJMSCorrelationID

public void setJMSCorrelationID(java.lang.String correlationId)

Specified by:

setJMSCorrelationID in interface javax.jms.Message

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

isPersistent

public boolean isPersistent()

setPersistent

public void setPersistent(boolean value)

decodeString

protected static java.lang.String decodeString(byte[] data)
                                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

encodeString

protected static byte[] encodeString(java.lang.String data)
                              throws javax.jms.JMSException

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 destination)
                   throws javax.jms.JMSException

Specified by:

setJMSReplyTo in interface javax.jms.Message

Throws:

javax.jms.JMSException

setJMSReplyTo

public void setJMSReplyTo(StompJmsDestination destination)

getStompJmsReplyTo

public StompJmsDestination getStompJmsReplyTo()
                                       throws javax.jms.JMSException

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

getStompJmsDestination

public StompJmsDestination getStompJmsDestination()
                                           throws javax.jms.JMSException

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

setJMSDestination

public void setJMSDestination(StompJmsDestination destination)

getJMSDeliveryMode

public int getJMSDeliveryMode()

Specified by:

getJMSDeliveryMode in interface javax.jms.Message

setJMSDeliveryMode

public void setJMSDeliveryMode(int mode)

Specified by:

setJMSDeliveryMode in interface javax.jms.Message

isRedelivered

public boolean isRedelivered()

setRedelivered

public void setRedelivered(boolean redelivered)

getRedeliveryCounter

public int getRedeliveryCounter()

setRedeliveryCounter

public void setRedeliveryCounter(int deliveryCounter)

getJMSRedelivered

public boolean getJMSRedelivered()

Specified by:

getJMSRedelivered in interface javax.jms.Message

setJMSRedelivered

public void setJMSRedelivered(boolean redelivered)

Specified by:

setJMSRedelivered in interface javax.jms.Message

getJMSType

public java.lang.String getJMSType()

Specified by:

getJMSType in interface javax.jms.Message

setJMSType

public void setJMSType(java.lang.String type)

Specified by:

setJMSType in interface javax.jms.Message

getJMSExpiration

public long getJMSExpiration()

Specified by:

getJMSExpiration in interface javax.jms.Message

setJMSExpiration

public void setJMSExpiration(long expiration)

Specified by:

setJMSExpiration in interface javax.jms.Message

getJMSPriority

public int getJMSPriority()

Specified by:

getJMSPriority in interface javax.jms.Message

setJMSPriority

public void setJMSPriority(int priority)

Specified by:

setJMSPriority in interface javax.jms.Message

getProperties

public java.util.Map<java.lang.String,java.lang.Object> getProperties()
                                                               throws java.io.IOException

Throws:

java.io.IOException

clearProperties

public void clearProperties()

Specified by:

clearProperties in interface javax.jms.Message

setProperty

public void setProperty(java.lang.String name,
               java.lang.Object value)
                 throws java.io.IOException

Throws:

java.io.IOException

removeProperty

public void removeProperty(java.lang.String name)
                    throws java.io.IOException

Throws:

java.io.IOException

lazyCreateProperties

protected void lazyCreateProperties()
                             throws java.io.IOException

Throws:

java.io.IOException

propertyExists

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

Specified by:

propertyExists 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

getAllPropertyNames

public java.util.Enumeration getAllPropertyNames()
                                          throws javax.jms.JMSException

return all property names, including standard JMS properties and JMSX properties

Returns:

Enumeration of all property names on this 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

setObjectProperty

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

Throws:

javax.jms.JMSException

setProperties

public void setProperties(java.util.Map<java.lang.String,java.lang.Object> properties)
                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

checkValidObject

protected void checkValidObject(java.lang.Object value)
                         throws javax.jms.MessageFormatException

Throws:

javax.jms.MessageFormatException

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

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

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

setBooleanProperty

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

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

checkReadOnlyBody

protected void checkReadOnlyBody()
                          throws javax.jms.MessageNotWriteableException

Throws:

javax.jms.MessageNotWriteableException

getAcknowledgeCallback

public java.util.concurrent.Callable<java.lang.Void> getAcknowledgeCallback()

setAcknowledgeCallback

public void setAcknowledgeCallback(java.util.concurrent.Callable<java.lang.Void> acknowledgeCallback)

onSend

public void onSend()
            throws javax.jms.JMSException

Send operation event listener. Used to get the message ready to be sent.

Throws:

javax.jms.JMSException

storeContent

public void storeContent()
                  throws javax.jms.JMSException

serialize the payload

Throws:

javax.jms.JMSException

getConsumerId

public org.fusesource.hawtbuf.AsciiBuffer getConsumerId()

Returns:

the consumerId

getHeaderMap

protected java.util.Map<org.fusesource.hawtbuf.AsciiBuffer,org.fusesource.hawtbuf.AsciiBuffer> getHeaderMap()

getTransactionId

public org.fusesource.hawtbuf.AsciiBuffer getTransactionId()

Returns:

the transactionId

setTransactionId

public void setTransactionId(org.fusesource.hawtbuf.AsciiBuffer transactionId)

Parameters:

transactionId - the transactionId to set

getConnection

public StompJmsConnection getConnection()

setConnection

public void setConnection(StompJmsConnection connection)