com.latencybusters.jms.message
Class JMSMessage

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

Direct Known Subclasses:

JMSBytesMessage, JMSMapMessage, JMSObjectMessage, JMSStreamMessage, JMSTextMessage

public class JMSMessage
extends java.lang.Object

Field Summary

protected byte[]	data
com.latencybusters.lbm.LBMMessage	dataMsg
static int	DEFAULT_LENGTH
static java.lang.String	GROUP_ID
static java.lang.String	GROUP_SEQ
protected byte[]	header

Constructor Summary

JMSMessage()

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

Method Summary

void	ack(LBMMessage message)
void	acknowledge(LBMMessage message)
boolean	checkReadOnlyBody()
protected void	checkValidObject(java.lang.Object value)
void	clearBody()
void	clearProperties()
JMSMessage	copy()
protected void	copy(JMSMessage copy)
com.latencybusters.lbm.LBMMessageProperties	copyProps(com.latencybusters.lbm.LBMMessageProperties props)
void	dumpProps()
boolean	equals(java.lang.Object o)
boolean	getAcked()
int	getAcknowledgeMode()
long	getBodyLength()
boolean	getBooleanProperty(java.lang.String name)
byte	getByteProperty(java.lang.String name)
LBMMessageConsumer	getConsumer()
byte[]	getData()
protected 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()
javax.jms.MessageListener	getListener()
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	isReadOnlyProps()
boolean	isShouldAck()
boolean	isValid(java.lang.String name)
void	logProps()
static void	main(java.lang.String[] args)
void	onSend() This method has not been implemented.
boolean	propertyExists(java.lang.String name)
void	reAssign()
void	setAcked(boolean acked)
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 id)
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	setReadOnlyProps(boolean readOnlyProps)
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)
boolean	verifySet(java.lang.String name)

Methods inherited from class java.lang.Object

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

Field Detail

dataMsg

public com.latencybusters.lbm.LBMMessage dataMsg

header

protected byte[] header

DEFAULT_LENGTH

public static final int DEFAULT_LENGTH

See Also:

Constant Field Values

data

protected byte[] data

GROUP_SEQ

public static final java.lang.String GROUP_SEQ

See Also:

Constant Field Values

GROUP_ID

public static final java.lang.String GROUP_ID

See Also:

Constant Field Values

Constructor Detail

JMSMessage

public JMSMessage()

JMSMessage

public JMSMessage(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(LBMMessage message)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

ack

public void ack(LBMMessage message)
         throws javax.jms.JMSException

Throws:

javax.jms.JMSException

checkReadOnlyBody

public boolean checkReadOnlyBody()
                          throws javax.jms.JMSException

Throws:

javax.jms.JMSException

checkValidObject

protected void checkValidObject(java.lang.Object value)

clearBody

public void clearBody()
               throws javax.jms.JMSException

Throws:

javax.jms.JMSException

clearProperties

public void clearProperties()

copy

public JMSMessage copy()

copy

protected void copy(JMSMessage 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

Throws:

javax.jms.JMSException

getByteProperty

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

Throws:

javax.jms.JMSException

getDoubleProperty

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

Throws:

javax.jms.JMSException

getFloatProperty

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

Throws:

javax.jms.JMSException

getIntProperty

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

Throws:

javax.jms.JMSException

getJMSCorrelationID

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

Throws:

javax.jms.JMSException

getJMSCorrelationIDAsBytes

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

Throws:

javax.jms.JMSException

getJMSDeliveryMode

public int getJMSDeliveryMode()
                       throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getDefaultDeliveryMode

public boolean getDefaultDeliveryMode()

getJMSDestination

public javax.jms.Destination getJMSDestination()

getJMSExpiration

public long getJMSExpiration()

getJMSMessageID

public java.lang.String getJMSMessageID()

getJMSPriority

public int getJMSPriority()
                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getJMSRedelivered

public boolean getJMSRedelivered()

getJMSReplyTo

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

Throws:

javax.jms.JMSException

getJMSTimestamp

public long getJMSTimestamp()
                     throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getJMSType

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

Throws:

javax.jms.JMSException

getMessageType

public int getMessageType()

getJMSXMimeType

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

Throws:

javax.jms.JMSException

getPropertyNames

public java.util.Enumeration getPropertyNames()

getLongProperty

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

Throws:

javax.jms.JMSException

setLongProperty

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

Throws:

javax.jms.JMSException

getObjectProperty

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

setObjectProperty

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

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

getShortProperty

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

Throws:

javax.jms.JMSException

setShortProperty

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

Throws:

javax.jms.JMSException

getStringProperty

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

Throws:

javax.jms.JMSException

setStringProperty

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

Throws:

javax.jms.JMSException

isExpired

public boolean isExpired()

This method has not been implemented.

onSend

public void onSend()

This method has not been implemented.

setJMSCorrelationID

public void setJMSCorrelationID(java.lang.String id)

setJMSCorrelationIDAsBytes

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

Throws:

javax.jms.JMSException

setJMSDeliveryMode

public void setJMSDeliveryMode(int mode)

setJMSDestination

public void setJMSDestination(javax.jms.Destination destination)

setJMSExpiration

public void setJMSExpiration(long expiration)

setJMSMessageID

public void setJMSMessageID(java.lang.String value)

setJMSPriority

public void setJMSPriority(int priority)

setJMSRedelivered

public void setJMSRedelivered(boolean redelivered)

setJMSReplyTo

public void setJMSReplyTo(javax.jms.Destination replyTo)

setJMSTimestamp

public void setJMSTimestamp(long timestamp)

setJMSType

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

Throws:

javax.jms.JMSException

setAcknowledgeCallback

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

This method has not been implemented.

propertyExists

public boolean propertyExists(java.lang.String name)

setBooleanProperty

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

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

Throws:

javax.jms.JMSException

setDoubleProperty

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

Throws:

javax.jms.JMSException

setFloatProperty

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

Throws:

javax.jms.JMSException

setIntProperty

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

Throws:

javax.jms.JMSException

setProperties

public void setProperties(java.util.Map properties)

getDataMsg

protected com.latencybusters.lbm.LBMMessage getDataMsg()

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

isReadOnlyProps

public boolean isReadOnlyProps()

Returns:

the readOnly

setReadOnlyProps

public void setReadOnlyProps(boolean readOnlyProps)

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

setListener

public void setListener(javax.jms.MessageListener listener)

Parameters:

listener - the listener to set

getListener

public javax.jms.MessageListener getListener()

setAcknowledgeMode

public void setAcknowledgeMode(int acknowledgeMode)

Parameters:

acknowledgeMode - the acknowledgeMode to set

getAcknowledgeMode

public int getAcknowledgeMode()

getAcked

public boolean getAcked()

setAcked

public void setAcked(boolean acked)

getRefCount

public int getRefCount()

Returns:

the refCount

setRefCount

public void setRefCount(int refCount)

Parameters:

refCount - the refCount to set

verifySet

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

Throws:

javax.jms.JMSException

isValid

public boolean isValid(java.lang.String name)

dumpProps

public void dumpProps()

copyProps

public com.latencybusters.lbm.LBMMessageProperties copyProps(com.latencybusters.lbm.LBMMessageProperties props)

logProps

public void logProps()

main

public static void main(java.lang.String[] args)