com.latencybusters.jms.message
Class LBMMessage

java.lang.Object
  com.latencybusters.jms.message.LBMMessage

All Implemented Interfaces:

javax.jms.Message

Direct Known Subclasses:

LBMBytesMessage, LBMMapMessage, LBMObjectMessage, LBMStreamMessage, LBMTextMessage

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

Field Summary

static int	BYTEMESSAGE
protected JMSMessage	m
static int	MAPMESSAGE
static int	MESSAGE
static int	OBJECTMESSAGE
static int	STREAMMESSAGE
static int	TEXTMESSAGE

Fields inherited from interface javax.jms.Message

DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE

Constructor Summary

LBMMessage()

LBMMessage(JMSMessage m)

LBMMessage(com.latencybusters.lbm.LBMMessageProperties props, byte[] data)

Method Summary

void	ack()
void	acknowledge()
boolean	checkReadOnlyBody()
protected void	checkRef()
void	clearBody()
void	clearProperties()
LBMMessage	copy()
void	dispatch()
void	dumpProps()
boolean	equals(java.lang.Object o)
long	getBodyLength()
boolean	getBooleanProperty(java.lang.String name)
byte	getByteProperty(java.lang.String name)
LBMMessageConsumer	getConsumer()
byte[]	getData()
com.latencybusters.lbm.LBMMessage	getDataMsg()
boolean	getDefaultDeliveryMode()
double	getDoubleProperty(java.lang.String name)
float	getFloatProperty(java.lang.String name)
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()
java.lang.String	getJMSXMimeType()
long	getLongProperty(java.lang.String name)
int	getMessageType()
java.lang.Object	getObjectProperty(java.lang.String name)
java.util.Enumeration	getPropertyNames()
com.latencybusters.lbm.LBMMessageProperties	getProps()
int	getRefCount()
short	getShortProperty(java.lang.String name)
java.lang.String	getStringProperty(java.lang.String name)
java.lang.String	getTopicName()
boolean	isExpired() This method has not been implemented.
boolean	isReadOnly()
boolean	isShouldAck()
void	logProps()
void	onSend() This method has not been implemented.
boolean	propertyExists(java.lang.String name)
void	reAssign()
void	setAcknowledgeCallback(javax.security.auth.callback.Callback acknowledgeCallback) This method has not been implemented.
void	setAcknowledgeMode(int acknowledgeMode)
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	setConsumer(LBMMessageConsumer consumer)
void	setDataMsg(com.latencybusters.lbm.LBMMessage dataMsg) This is an internal Method.
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[] b)
void	setJMSDeliveryMode(int mode)
void	setJMSDestination(javax.jms.Destination destination)
void	setJMSExpiration(long expiration)
void	setJMSMessageID(java.lang.String value)
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	setListener(javax.jms.MessageListener listener)
void	setLongProperty(java.lang.String name, long value)
void	setObjectProperty(java.lang.String name, java.lang.Object value)
void	setObjectProperty(java.lang.String name, java.lang.Object value, boolean checkReadOnly)
void	setProperties(java.util.Map properties)
void	setReadOnly(boolean readOnly)
void	setRefCount(int refCount)
void	setShortProperty(java.lang.String name, short value)
void	setShouldAck(boolean shouldAck)
void	setStringProperty(java.lang.String name, java.lang.String value)
void	setTopicname(java.lang.String topicName)

Methods inherited from class java.lang.Object

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

Field Detail

TEXTMESSAGE

public static final int TEXTMESSAGE

See Also:

Constant Field Values

BYTEMESSAGE

public static final int BYTEMESSAGE

See Also:

Constant Field Values

MAPMESSAGE

public static final int MAPMESSAGE

See Also:

Constant Field Values

MESSAGE

public static final int MESSAGE

See Also:

Constant Field Values

OBJECTMESSAGE

public static final int OBJECTMESSAGE

See Also:

Constant Field Values

STREAMMESSAGE

public static final int STREAMMESSAGE

See Also:

Constant Field Values

m

protected JMSMessage m

Constructor Detail

LBMMessage

public LBMMessage()

LBMMessage

public LBMMessage(JMSMessage m)

LBMMessage

public LBMMessage(com.latencybusters.lbm.LBMMessageProperties props,
                  byte[] data)

Method Detail

getData

public byte[] getData()

getProps

public com.latencybusters.lbm.LBMMessageProperties getProps()

getBodyLength

public long getBodyLength()

reAssign

public void reAssign()
              throws javax.jms.JMSException

Throws:

javax.jms.JMSException

acknowledge

public void acknowledge()
                 throws javax.jms.JMSException

Specified by:

acknowledge in interface javax.jms.Message

Throws:

javax.jms.JMSException

ack

public void ack()
         throws javax.jms.JMSException

Throws:

javax.jms.JMSException

checkReadOnlyBody

public boolean checkReadOnlyBody()
                          throws javax.jms.JMSException

Throws:

javax.jms.JMSException

clearBody

public void clearBody()
               throws javax.jms.JMSException

Specified by:

clearBody in interface javax.jms.Message

Throws:

javax.jms.JMSException

clearProperties

public void clearProperties()

Specified by:

clearProperties in interface javax.jms.Message

copy

public LBMMessage copy()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

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

getDoubleProperty

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

Specified by:

getDoubleProperty 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

getIntProperty

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

Specified by:

getIntProperty 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

getJMSCorrelationIDAsBytes

public byte[] getJMSCorrelationIDAsBytes()
                                  throws javax.jms.JMSException

Specified by:

getJMSCorrelationIDAsBytes 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

getDefaultDeliveryMode

public boolean getDefaultDeliveryMode()

getJMSDestination

public javax.jms.Destination getJMSDestination()

Specified by:

getJMSDestination in interface javax.jms.Message

getJMSExpiration

public long getJMSExpiration()

Specified by:

getJMSExpiration in interface javax.jms.Message

getJMSMessageID

public java.lang.String getJMSMessageID()

Specified by:

getJMSMessageID in interface javax.jms.Message

getJMSPriority

public int getJMSPriority()
                   throws javax.jms.JMSException

Specified by:

getJMSPriority 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

getJMSReplyTo

public javax.jms.Destination getJMSReplyTo()
                                    throws javax.jms.JMSException

Specified by:

getJMSReplyTo 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

getJMSType

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

Specified by:

getJMSType in interface javax.jms.Message

Throws:

javax.jms.JMSException

getMessageType

public int getMessageType()

getJMSXMimeType

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

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

getObjectProperty

public java.lang.Object getObjectProperty(java.lang.String name)

Specified by:

getObjectProperty in interface javax.jms.Message

getPropertyNames

public java.util.Enumeration getPropertyNames()

Specified by:

getPropertyNames in interface javax.jms.Message

getShortProperty

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

Specified by:

getShortProperty 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

isExpired

public boolean isExpired()

This method has not been implemented.

onSend

public void onSend()

This method has not been implemented.

propertyExists

public boolean propertyExists(java.lang.String name)

Specified by:

propertyExists in interface javax.jms.Message

setAcknowledgeCallback

public void setAcknowledgeCallback(javax.security.auth.callback.Callback acknowledgeCallback)

This method has not been implemented.

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

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

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

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

setJMSCorrelationID

public void setJMSCorrelationID(java.lang.String correlationId)

Specified by:

setJMSCorrelationID in interface javax.jms.Message

setJMSCorrelationIDAsBytes

public void setJMSCorrelationIDAsBytes(byte[] b)
                                throws javax.jms.JMSException

Specified by:

setJMSCorrelationIDAsBytes in interface javax.jms.Message

Throws:

javax.jms.JMSException

setJMSDeliveryMode

public void setJMSDeliveryMode(int mode)

Specified by:

setJMSDeliveryMode in interface javax.jms.Message

setJMSDestination

public void setJMSDestination(javax.jms.Destination destination)

Specified by:

setJMSDestination in interface javax.jms.Message

setJMSExpiration

public void setJMSExpiration(long expiration)

Specified by:

setJMSExpiration in interface javax.jms.Message

setJMSMessageID

public void setJMSMessageID(java.lang.String value)

Specified by:

setJMSMessageID in interface javax.jms.Message

setJMSPriority

public void setJMSPriority(int priority)

Specified by:

setJMSPriority in interface javax.jms.Message

setJMSRedelivered

public void setJMSRedelivered(boolean redelivered)

Specified by:

setJMSRedelivered in interface javax.jms.Message

setJMSReplyTo

public void setJMSReplyTo(javax.jms.Destination replyTo)

Specified by:

setJMSReplyTo in interface javax.jms.Message

setJMSTimestamp

public void setJMSTimestamp(long timestamp)

Specified by:

setJMSTimestamp in interface javax.jms.Message

setJMSType

public void setJMSType(java.lang.String type)
                throws javax.jms.JMSException

Specified by:

setJMSType 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

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 properties)

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

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

getDataMsg

public com.latencybusters.lbm.LBMMessage getDataMsg()

Returns:

the msg

setDataMsg

public void setDataMsg(com.latencybusters.lbm.LBMMessage dataMsg)

This is an internal Method.

isReadOnly

public boolean isReadOnly()

Returns:

the readOnly

setReadOnly

public void setReadOnly(boolean readOnly)

Parameters:

readOnly - the readOnly to set

isShouldAck

public boolean isShouldAck()

Returns:

the shouldAck

setShouldAck

public void setShouldAck(boolean shouldAck)

Parameters:

shouldAck - the shouldAck to set

getTopicName

public java.lang.String getTopicName()

setTopicname

public void setTopicname(java.lang.String topicName)

getConsumer

public LBMMessageConsumer getConsumer()

Returns:

the consumer

setConsumer

public void setConsumer(LBMMessageConsumer consumer)

Parameters:

consumer - the consumer to set

dispatch

public void dispatch()
              throws javax.jms.JMSException

Throws:

javax.jms.JMSException

setListener

public void setListener(javax.jms.MessageListener listener)

Parameters:

listener - the listener to set

setAcknowledgeMode

public void setAcknowledgeMode(int acknowledgeMode)

Parameters:

acknowledgeMode - the acknowledgeMode to set

dumpProps

public void dumpProps()

logProps

public void logProps()

getRefCount

public int getRefCount()

Returns:

the refCount

setRefCount

public void setRefCount(int refCount)

Parameters:

refCount - the refCount to set

checkRef

protected void checkRef()