org.qbroker.jms

Class JMSEvent

java.lang.Object

org.qbroker.event.Event

org.qbroker.jms.JMSEvent

All Implemented Interfaces:

javax.jms.Message, Event

Direct Known Subclasses:

BytesEvent, MapEvent, ObjectEvent, TextEvent

public class JMSEvent
extends Event
implements javax.jms.Message

JMSEvent is an Event that implements JMS Message

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_DELIVERY_MODE
static int	DEFAULT_PRIORITY
static int	DEFAULT_TIME_TO_LIVE
static int	TYPE_BOOLEAN
static int	TYPE_BYTE
static int	TYPE_DOUBLE
static int	TYPE_FLOAT
static int	TYPE_INTEGER
static int	TYPE_LONG
static int	TYPE_SHORT
static int	TYPE_STRING
protected boolean	writeable

Fields inherited from class org.qbroker.event.Event

attribute, body, deliveryMode, ESCAPED_AMPERSAND, ESCAPED_CARRIAGE_RETURN, ESCAPED_EQUAL, ESCAPED_ITEM_SEPARATOR, ESCAPED_QUOTE, eventID, expiration, groupID, ITEM_SEPARATOR, LOG_CENTRAL, LOG_COMPACT, LOG_JMS, LOG_LOCAL, LOG_SYSLOG, logMode, timestamp

Fields inherited from interface org.qbroker.common.Event

ALERT, CRIT, DEBUG, EMERG, ERR, INFO, NONE, NOTICE, priorityNames, TRACE, WARNING

Constructor Summary

Constructors

Constructor and Description
JMSEvent()

Method Summary

Modifier and Type	Method and Description
void	acknowledge()
void	clearBody()
void	clearProperties()
protected void	finalize()
boolean	getBooleanProperty(java.lang.String name)
byte	getByteProperty(java.lang.String name)
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()
long	getLongProperty(java.lang.String name)
java.lang.Object	getObjectProperty(java.lang.String name)
java.util.Enumeration	getPropertyNames()
short	getShortProperty(java.lang.String name)
java.lang.String	getStringProperty(java.lang.String name)
protected boolean	isValid(java.lang.Object obj)
boolean	propertyExists(java.lang.String name)
void	setAckObject(java.lang.Object obj, java.lang.reflect.Method method, long[] state)
void	setBooleanProperty(java.lang.String name, boolean x)
void	setByteProperty(java.lang.String name, byte x)
void	setDoubleProperty(java.lang.String name, double x)
void	setFloatProperty(java.lang.String name, float x)
void	setIntProperty(java.lang.String name, int x)
void	setJMSCorrelationID(java.lang.String id)
void	setJMSCorrelationIDAsBytes(byte[] id)
void	setJMSDeliveryMode(int d)
void	setJMSDestination(javax.jms.Destination dst)
void	setJMSExpiration(long ts)
void	setJMSMessageID(java.lang.String id)
void	setJMSPriority(int p)
void	setJMSRedelivered(boolean x)
void	setJMSReplyTo(javax.jms.Destination replyTo)
void	setJMSTimestamp(long ts)
void	setJMSType(java.lang.String type)
void	setLongProperty(java.lang.String name, long x)
void	setObjectProperty(java.lang.String name, java.lang.Object x)
void	setShortProperty(java.lang.String name, short x)
void	setStringProperty(java.lang.String name, java.lang.String x)

Methods inherited from class org.qbroker.event.Event

attributeExists, clearAttributes, dateFormat, flush, getAttribute, getAttributeNames, getBody, getDefaultName, getExpiration, getGroupID, getHostID, getHostName, getIPAddress, getPID, getPriority, getPriorityByName, getProgramName, getTimestamp, log, parseDate, print, removeAttribute, send, setAttribute, setBody, setDefaultCategory, setDefaultName, setDefaultSite, setDefaultType, setExpiration, setGroupID, setLogDir, setLogDir, setLogDir, setPriority, setTimestamp, traceStack

Methods inherited from class java.lang.Object

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

Field Detail

writeable

protected boolean writeable

DEFAULT_DELIVERY_MODE

public static final int DEFAULT_DELIVERY_MODE

See Also:

Constant Field Values

DEFAULT_PRIORITY

public static final int DEFAULT_PRIORITY

See Also:

Constant Field Values

DEFAULT_TIME_TO_LIVE

public static final int DEFAULT_TIME_TO_LIVE

See Also:

Constant Field Values

TYPE_STRING

public static final int TYPE_STRING

See Also:

Constant Field Values

TYPE_BOOLEAN

public static final int TYPE_BOOLEAN

See Also:

Constant Field Values

TYPE_BYTE

public static final int TYPE_BYTE

See Also:

Constant Field Values

TYPE_SHORT

public static final int TYPE_SHORT

See Also:

Constant Field Values

TYPE_INTEGER

public static final int TYPE_INTEGER

See Also:

Constant Field Values

TYPE_LONG

public static final int TYPE_LONG

See Also:

Constant Field Values

TYPE_FLOAT

public static final int TYPE_FLOAT

See Also:

Constant Field Values

TYPE_DOUBLE

public static final int TYPE_DOUBLE

See Also:

Constant Field Values

Constructor Detail

JMSEvent

public JMSEvent()

Method Detail

acknowledge

public void acknowledge()
                 throws javax.jms.JMSException

Specified by:

acknowledge 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

getJMSMessageID

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

Specified by:

getJMSMessageID in interface javax.jms.Message

Throws:

javax.jms.JMSException

setJMSCorrelationID

public void setJMSCorrelationID(java.lang.String id)
                         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

setJMSCorrelationIDAsBytes

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

Specified by:

setJMSCorrelationIDAsBytes 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

setJMSTimestamp

public void setJMSTimestamp(long ts)
                     throws javax.jms.JMSException

Specified by:

setJMSTimestamp 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

setJMSReplyTo

public void setJMSReplyTo(javax.jms.Destination replyTo)
                   throws javax.jms.JMSException

Specified by:

setJMSReplyTo 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

setJMSDestination

public void setJMSDestination(javax.jms.Destination dst)
                       throws javax.jms.JMSException

Specified by:

setJMSDestination 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

setJMSDeliveryMode

public void setJMSDeliveryMode(int d)
                        throws javax.jms.JMSException

Specified by:

setJMSDeliveryMode 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

setJMSRedelivered

public void setJMSRedelivered(boolean x)
                       throws javax.jms.JMSException

Specified by:

setJMSRedelivered 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

setJMSType

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

Specified by:

setJMSType 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

setJMSExpiration

public void setJMSExpiration(long ts)
                      throws javax.jms.JMSException

Specified by:

setJMSExpiration 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

setJMSPriority

public void setJMSPriority(int p)
                    throws javax.jms.JMSException

Specified by:

setJMSPriority 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

clearBody

public void clearBody()
               throws javax.jms.JMSException

Specified by:

clearBody in interface javax.jms.Message

Throws:

javax.jms.JMSException

clearProperties

public void clearProperties()
                     throws javax.jms.JMSException

Specified by:

clearProperties in interface javax.jms.Message

Throws:

javax.jms.JMSException

setBooleanProperty

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

Specified by:

setBooleanProperty 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

setByteProperty

public void setByteProperty(java.lang.String name,
                            byte x)
                     throws javax.jms.JMSException

Specified by:

setByteProperty 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

setShortProperty

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

Specified by:

setShortProperty 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

setIntProperty

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

Specified by:

setIntProperty 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

setLongProperty

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

Specified by:

setLongProperty 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

setFloatProperty

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

Specified by:

setFloatProperty 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

setDoubleProperty

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

Specified by:

setDoubleProperty 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

setStringProperty

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

Specified by:

setStringProperty 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

setObjectProperty

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

Specified by:

setObjectProperty 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

propertyExists

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

Specified by:

propertyExists in interface javax.jms.Message

Throws:

javax.jms.JMSException

setAckObject

public void setAckObject(java.lang.Object obj,
                         java.lang.reflect.Method method,
                         long[] state)

isValid

protected boolean isValid(java.lang.Object obj)

finalize

protected void finalize()

Overrides:

finalize in class Event