cgl.narada.jms
Class JmsMessage

java.lang.Object
  extended by cgl.narada.jms.JmsMessage
All Implemented Interfaces:
Message
Direct Known Subclasses:
JmsBytesMessage, JmsMapMessage, JmsObjectMessage, JmsStreamMessage, JmsTextMessage

public class JmsMessage
extends Object
implements Message

This class implements the Message interface specified in the JMS specification.


Field Summary
 
Fields inherited from interface javax.jms.Message
DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE
 
Constructor Summary
JmsMessage()
           
 
Method Summary
 void acknowledge()
           
 void clearBody()
           
 void clearProperties()
           
 boolean getBooleanProperty(String name)
           
 byte getByteProperty(String name)
           
 byte[] getBytes()
           
 double getDoubleProperty(String name)
           
 float getFloatProperty(String name)
           
 int getIntProperty(String name)
           
 String getJMSCorrelationID()
           
 byte[] getJMSCorrelationIDAsBytes()
           
 int getJMSDeliveryMode()
           
 Destination getJMSDestination()
           
 long getJMSExpiration()
           
 String getJMSMessageID()
           
 int getJMSPriority()
           
 boolean getJMSRedelivered()
           
 Destination getJMSReplyTo()
           
 long getJMSTimestamp()
           
 String getJMSType()
           
 long getLongProperty(String name)
           
 Object getObjectProperty(String name)
           
 Enumeration getPropertyNames()
           
 short getShortProperty(String name)
           
 String getStringProperty(String name)
           
 boolean propertyExists(String name)
           
protected  void setBodyAndPropertyAsReadOnly()
           
 void setBooleanProperty(String name, boolean value)
           
 void setByteProperty(String name, byte value)
           
 void setDoubleProperty(String name, double value)
           
 void setFloatProperty(String name, float value)
           
 void setIntProperty(String name, int value)
           
 void setJMSCorrelationID(String correlationID)
           
 void setJMSCorrelationIDAsBytes(byte[] correlationID)
           
 void setJMSDeliveryMode(int deliveryMode)
           
 void setJMSDestination(Destination destination)
           
 void setJMSExpiration(long expiration)
           
 void setJMSMessageID(String id)
           
 void setJMSPriority(int priority)
           
 void setJMSRedelivered(boolean redelivered)
           
 void setJMSReplyTo(Destination replyTo)
           
 void setJMSTimestamp(long timestamp)
           
 void setJMSType(String type)
           
 void setLongProperty(String name, long value)
           
 void setObjectProperty(String name, Object value)
           
 void setShortProperty(String name, short value)
           
 void setStringProperty(String name, String value)
           
protected  void testReadBody()
           
protected  void testWriteBody()
           
protected  void testWriteProperties()
           
 String toString()
           
 void unmarshallJmsMessage(byte[] messageBytes)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

JmsMessage

public JmsMessage()
Method Detail

getJMSMessageID

public String getJMSMessageID()
                       throws JMSException
Specified by:
getJMSMessageID in interface Message
Throws:
JMSException

setJMSMessageID

public void setJMSMessageID(String id)
                     throws JMSException
Specified by:
setJMSMessageID in interface Message
Throws:
JMSException

getJMSTimestamp

public long getJMSTimestamp()
                     throws JMSException
Specified by:
getJMSTimestamp in interface Message
Throws:
JMSException

setJMSTimestamp

public void setJMSTimestamp(long timestamp)
                     throws JMSException
Specified by:
setJMSTimestamp in interface Message
Throws:
JMSException

getJMSCorrelationIDAsBytes

public byte[] getJMSCorrelationIDAsBytes()
                                  throws JMSException
Specified by:
getJMSCorrelationIDAsBytes in interface Message
Throws:
JMSException

setJMSCorrelationIDAsBytes

public void setJMSCorrelationIDAsBytes(byte[] correlationID)
                                throws JMSException
Specified by:
setJMSCorrelationIDAsBytes in interface Message
Throws:
JMSException

getJMSCorrelationID

public String getJMSCorrelationID()
                           throws JMSException
Specified by:
getJMSCorrelationID in interface Message
Throws:
JMSException

setJMSCorrelationID

public void setJMSCorrelationID(String correlationID)
                         throws JMSException
Specified by:
setJMSCorrelationID in interface Message
Throws:
JMSException

getJMSReplyTo

public Destination getJMSReplyTo()
                          throws JMSException
Specified by:
getJMSReplyTo in interface Message
Throws:
JMSException

setJMSReplyTo

public void setJMSReplyTo(Destination replyTo)
                   throws JMSException
Specified by:
setJMSReplyTo in interface Message
Throws:
JMSException

getJMSDestination

public Destination getJMSDestination()
                              throws JMSException
Specified by:
getJMSDestination in interface Message
Throws:
JMSException

setJMSDestination

public void setJMSDestination(Destination destination)
                       throws JMSException
Specified by:
setJMSDestination in interface Message
Throws:
JMSException

getJMSDeliveryMode

public int getJMSDeliveryMode()
                       throws JMSException
Specified by:
getJMSDeliveryMode in interface Message
Throws:
JMSException

setJMSDeliveryMode

public void setJMSDeliveryMode(int deliveryMode)
                        throws JMSException
Specified by:
setJMSDeliveryMode in interface Message
Throws:
JMSException

getJMSRedelivered

public boolean getJMSRedelivered()
                          throws JMSException
Specified by:
getJMSRedelivered in interface Message
Throws:
JMSException

setJMSRedelivered

public void setJMSRedelivered(boolean redelivered)
                       throws JMSException
Specified by:
setJMSRedelivered in interface Message
Throws:
JMSException

getJMSType

public String getJMSType()
                  throws JMSException
Specified by:
getJMSType in interface Message
Throws:
JMSException

setJMSType

public void setJMSType(String type)
                throws JMSException
Specified by:
setJMSType in interface Message
Throws:
JMSException

getJMSExpiration

public long getJMSExpiration()
                      throws JMSException
Specified by:
getJMSExpiration in interface Message
Throws:
JMSException

setJMSExpiration

public void setJMSExpiration(long expiration)
                      throws JMSException
Specified by:
setJMSExpiration in interface Message
Throws:
JMSException

getJMSPriority

public int getJMSPriority()
                   throws JMSException
Specified by:
getJMSPriority in interface Message
Throws:
JMSException

setJMSPriority

public void setJMSPriority(int priority)
                    throws JMSException
Specified by:
setJMSPriority in interface Message
Throws:
JMSException

clearProperties

public void clearProperties()
                     throws JMSException
Specified by:
clearProperties in interface Message
Throws:
JMSException

propertyExists

public boolean propertyExists(String name)
                       throws JMSException
Specified by:
propertyExists in interface Message
Throws:
JMSException

getBooleanProperty

public boolean getBooleanProperty(String name)
                           throws JMSException
Specified by:
getBooleanProperty in interface Message
Throws:
JMSException

setBooleanProperty

public void setBooleanProperty(String name,
                               boolean value)
                        throws JMSException
Specified by:
setBooleanProperty in interface Message
Throws:
JMSException

getByteProperty

public byte getByteProperty(String name)
                     throws JMSException
Specified by:
getByteProperty in interface Message
Throws:
JMSException

setByteProperty

public void setByteProperty(String name,
                            byte value)
                     throws JMSException
Specified by:
setByteProperty in interface Message
Throws:
JMSException

getShortProperty

public short getShortProperty(String name)
                       throws JMSException
Specified by:
getShortProperty in interface Message
Throws:
JMSException

setShortProperty

public void setShortProperty(String name,
                             short value)
                      throws JMSException
Specified by:
setShortProperty in interface Message
Throws:
JMSException

getIntProperty

public int getIntProperty(String name)
                   throws JMSException
Specified by:
getIntProperty in interface Message
Throws:
JMSException

setIntProperty

public void setIntProperty(String name,
                           int value)
                    throws JMSException
Specified by:
setIntProperty in interface Message
Throws:
JMSException

getLongProperty

public long getLongProperty(String name)
                     throws JMSException
Specified by:
getLongProperty in interface Message
Throws:
JMSException

setLongProperty

public void setLongProperty(String name,
                            long value)
                     throws JMSException
Specified by:
setLongProperty in interface Message
Throws:
JMSException

getFloatProperty

public float getFloatProperty(String name)
                       throws JMSException
Specified by:
getFloatProperty in interface Message
Throws:
JMSException

setFloatProperty

public void setFloatProperty(String name,
                             float value)
                      throws JMSException
Specified by:
setFloatProperty in interface Message
Throws:
JMSException

getDoubleProperty

public double getDoubleProperty(String name)
                         throws JMSException
Specified by:
getDoubleProperty in interface Message
Throws:
JMSException

setDoubleProperty

public void setDoubleProperty(String name,
                              double value)
                       throws JMSException
Specified by:
setDoubleProperty in interface Message
Throws:
JMSException

getStringProperty

public String getStringProperty(String name)
                         throws JMSException
Specified by:
getStringProperty in interface Message
Throws:
JMSException

setStringProperty

public void setStringProperty(String name,
                              String value)
                       throws JMSException
Specified by:
setStringProperty in interface Message
Throws:
JMSException

getObjectProperty

public Object getObjectProperty(String name)
                         throws JMSException
Specified by:
getObjectProperty in interface Message
Throws:
JMSException

setObjectProperty

public void setObjectProperty(String name,
                              Object value)
                       throws JMSException
Specified by:
setObjectProperty in interface Message
Throws:
JMSException

getPropertyNames

public Enumeration getPropertyNames()
                             throws JMSException
Specified by:
getPropertyNames in interface Message
Throws:
JMSException

clearBody

public void clearBody()
               throws JMSException
Specified by:
clearBody in interface Message
Throws:
JMSException

acknowledge

public void acknowledge()
                 throws JMSException
Specified by:
acknowledge in interface Message
Throws:
JMSException

testWriteBody

protected void testWriteBody()
                      throws MessageNotWriteableException
Throws:
MessageNotWriteableException

testReadBody

protected void testReadBody()
                     throws MessageNotReadableException
Throws:
MessageNotReadableException

testWriteProperties

protected void testWriteProperties()
                            throws MessageNotWriteableException
Throws:
MessageNotWriteableException

setBodyAndPropertyAsReadOnly

protected void setBodyAndPropertyAsReadOnly()

getBytes

public byte[] getBytes()

unmarshallJmsMessage

public void unmarshallJmsMessage(byte[] messageBytes)

toString

public String toString()
Overrides:
toString in class Object


For comments and suggestions please send e-mail to The NaradaBrokering Project