Package com.webmethods.jms.transport
Class TransportMessage
- java.lang.Object
-
- com.webmethods.jms.transport.TransportMessage
-
- All Implemented Interfaces:
java.lang.Cloneable
public class TransportMessage extends java.lang.Object implements java.lang.Cloneable
-
-
Field Summary
Fields Modifier and Type Field Description protected TransportField
_bodyField
protected TransportVirtualStructField
_bodyStruct
protected TransportEnvelope
_envelope
protected TransportHeader
_eventHeader
protected boolean
_isJmsEvent
protected TransportStructField
_properties
protected int
_transportType
static int
GUARANTEED_STORAGE_TYPE
static int
TRANSPORT_TYPE_BYTES_MESSAGE
static int
TRANSPORT_TYPE_FILE_MESSAGE
static int
TRANSPORT_TYPE_MAP_MESSAGE
static int
TRANSPORT_TYPE_MESSAGE
static int
TRANSPORT_TYPE_OBJECT_MESSAGE
static int
TRANSPORT_TYPE_STREAM_MESSAGE
static int
TRANSPORT_TYPE_TEXT_MESSAGE
static int
VOLATILE_STORAGE_TYPE
-
Constructor Summary
Constructors Constructor Description TransportMessage(byte[] data, int dataOffset, int dataLength)
TransportMessage(int transportMessageType)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
clearBody()
void
clearProperties()
java.lang.Object
clone()
boolean
fieldExists(java.lang.String name)
short[]
getAccessLabel()
byte[]
getBytesBody()
byte[]
getCompressedTransportData(CompressionManager compressionManager)
java.lang.String
getDestinationId()
java.lang.Object
getField(int index)
java.lang.Object
getField(java.lang.String name)
java.util.Vector<java.lang.String>
getFieldNames()
java.lang.String
getJMSCorrelationID()
int
getJMSDeliveryMode()
java.lang.String
getJMSDestination()
long
getJMSExpiration()
java.lang.String
getJMSMessageID()
int
getJMSPriority()
long
getJMSTimestamp()
java.lang.String
getJMSType()
int
getNumberOfFields()
int
getNumberOfProperties()
byte[]
getObjectBody()
java.lang.String
getPreAcknowledgement()
java.lang.Object
getProperty(java.lang.String name)
java.util.Enumeration<java.lang.String>
getPropertyNames()
java.lang.String
getReplyTo()
java.lang.String
getReplyToDestination()
java.lang.String
getText()
java.lang.String
getTopicName()
byte[]
getTransportData()
int
getTransportDataLength()
int
getTransportMessageType()
java.lang.String
getTransportTypeName()
java.lang.String
getUUID()
boolean
propertyExists(java.lang.String propertyName)
void
setAccessLabel(short[] label)
void
setBooleanField(int index, boolean value)
void
setBooleanField(java.lang.String name, boolean value)
void
setBooleanProperty(java.lang.String name, boolean value)
void
setByteArrayField(int index, byte[] value)
void
setByteArrayField(java.lang.String name, byte[] value)
void
setByteArrayProperty(java.lang.String name, byte[] value)
void
setByteField(int index, byte value)
void
setByteField(java.lang.String name, byte value)
void
setByteProperty(java.lang.String name, byte value)
void
setBytesBody(byte[] value)
void
setCharField(int index, char value)
void
setCharField(java.lang.String name, char value)
void
setDestinationId(java.lang.String destId)
void
setDoubleField(int index, double value)
void
setDoubleField(java.lang.String name, double value)
void
setDoubleProperty(java.lang.String name, double value)
void
setFloatField(int index, float value)
void
setFloatField(java.lang.String name, float value)
void
setFloatProperty(java.lang.String name, float value)
void
setIntField(int index, int value)
void
setIntField(java.lang.String name, int value)
void
setIntProperty(java.lang.String name, int value)
void
setJMSCorrelationID(java.lang.String correlationId)
void
setJMSDeliveryMode(int deliveryMode)
void
setJMSDestination(java.lang.String destination)
void
setJMSExpiration(long expiration)
void
setJMSMessageID(java.lang.String msgId)
void
setJMSPriority(int priority)
void
setJMSTimestamp(long timestamp)
void
setJMSType(java.lang.String type)
void
setLongField(int index, long value)
void
setLongField(java.lang.String name, long value)
void
setLongProperty(java.lang.String name, long value)
void
setNullProperty(java.lang.String name)
void
setObjectBody(byte[] value)
void
setPreAcknowledgement(java.lang.String preack)
void
setReplyTo(java.lang.String destination)
void
setReplyToDestination(java.lang.String destination)
void
setShortField(int index, short value)
void
setShortField(java.lang.String name, short value)
void
setShortProperty(java.lang.String name, short value)
void
setStringField(int index, java.lang.String value)
void
setStringField(java.lang.String name, java.lang.String value)
void
setStringProperty(java.lang.String name, java.lang.String value)
void
setText(java.lang.String text)
void
setTopicName(java.lang.String topicName)
void
setTransportTypeName(java.lang.String name)
void
setUUID(java.lang.String uuid)
void
uncompress()
-
-
-
Field Detail
-
VOLATILE_STORAGE_TYPE
public static final int VOLATILE_STORAGE_TYPE
- See Also:
- Constant Field Values
-
GUARANTEED_STORAGE_TYPE
public static final int GUARANTEED_STORAGE_TYPE
- See Also:
- Constant Field Values
-
TRANSPORT_TYPE_MESSAGE
public static final int TRANSPORT_TYPE_MESSAGE
- See Also:
- Constant Field Values
-
TRANSPORT_TYPE_BYTES_MESSAGE
public static final int TRANSPORT_TYPE_BYTES_MESSAGE
- See Also:
- Constant Field Values
-
TRANSPORT_TYPE_TEXT_MESSAGE
public static final int TRANSPORT_TYPE_TEXT_MESSAGE
- See Also:
- Constant Field Values
-
TRANSPORT_TYPE_OBJECT_MESSAGE
public static final int TRANSPORT_TYPE_OBJECT_MESSAGE
- See Also:
- Constant Field Values
-
TRANSPORT_TYPE_STREAM_MESSAGE
public static final int TRANSPORT_TYPE_STREAM_MESSAGE
- See Also:
- Constant Field Values
-
TRANSPORT_TYPE_MAP_MESSAGE
public static final int TRANSPORT_TYPE_MAP_MESSAGE
- See Also:
- Constant Field Values
-
TRANSPORT_TYPE_FILE_MESSAGE
public static final int TRANSPORT_TYPE_FILE_MESSAGE
- See Also:
- Constant Field Values
-
_eventHeader
protected TransportHeader _eventHeader
-
_properties
protected TransportStructField _properties
-
_envelope
protected TransportEnvelope _envelope
-
_bodyStruct
protected TransportVirtualStructField _bodyStruct
-
_bodyField
protected TransportField _bodyField
-
_transportType
protected int _transportType
-
_isJmsEvent
protected boolean _isJmsEvent
-
-
Method Detail
-
uncompress
public void uncompress() throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
-
clone
public java.lang.Object clone()
- Overrides:
clone
in classjava.lang.Object
-
getTransportMessageType
public int getTransportMessageType()
-
getTransportTypeName
public java.lang.String getTransportTypeName()
-
setTransportTypeName
public void setTransportTypeName(java.lang.String name)
-
getDestinationId
public java.lang.String getDestinationId()
-
setDestinationId
public void setDestinationId(java.lang.String destId)
-
getTopicName
public java.lang.String getTopicName()
-
setTopicName
public void setTopicName(java.lang.String topicName)
-
getTransportDataLength
public int getTransportDataLength()
-
getTransportData
public byte[] getTransportData()
-
getCompressedTransportData
public byte[] getCompressedTransportData(CompressionManager compressionManager) throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
-
clearProperties
public void clearProperties()
-
propertyExists
public boolean propertyExists(java.lang.String propertyName)
-
getNumberOfProperties
public int getNumberOfProperties()
-
getPropertyNames
public java.util.Enumeration<java.lang.String> getPropertyNames()
-
clearBody
public void clearBody()
-
getProperty
public java.lang.Object getProperty(java.lang.String name)
-
getJMSDeliveryMode
public int getJMSDeliveryMode() throws TransportFieldNotFoundException
- Throws:
TransportFieldNotFoundException
-
getJMSPriority
public int getJMSPriority()
-
getJMSExpiration
public long getJMSExpiration()
-
getJMSTimestamp
public long getJMSTimestamp()
-
getJMSMessageID
public java.lang.String getJMSMessageID() throws TransportFieldNotFoundException
- Throws:
TransportFieldNotFoundException
-
getJMSDestination
public java.lang.String getJMSDestination() throws TransportFieldNotFoundException
- Throws:
TransportFieldNotFoundException
-
getReplyTo
public java.lang.String getReplyTo() throws TransportFieldNotFoundException
- Throws:
TransportFieldNotFoundException
-
getReplyToDestination
public java.lang.String getReplyToDestination() throws TransportFieldNotFoundException
- Throws:
TransportFieldNotFoundException
-
getJMSCorrelationID
public java.lang.String getJMSCorrelationID() throws TransportFieldNotFoundException
- Throws:
TransportFieldNotFoundException
-
getJMSType
public java.lang.String getJMSType() throws TransportFieldNotFoundException
- Throws:
TransportFieldNotFoundException
-
getAccessLabel
public short[] getAccessLabel()
-
getUUID
public java.lang.String getUUID()
-
getPreAcknowledgement
public java.lang.String getPreAcknowledgement()
-
setAccessLabel
public void setAccessLabel(short[] label)
-
setJMSDeliveryMode
public void setJMSDeliveryMode(int deliveryMode)
-
setJMSPriority
public void setJMSPriority(int priority)
-
setJMSExpiration
public void setJMSExpiration(long expiration)
-
setJMSTimestamp
public void setJMSTimestamp(long timestamp)
-
setJMSMessageID
public void setJMSMessageID(java.lang.String msgId)
-
setJMSDestination
public void setJMSDestination(java.lang.String destination)
-
setReplyTo
public void setReplyTo(java.lang.String destination)
-
setReplyToDestination
public void setReplyToDestination(java.lang.String destination)
-
setJMSCorrelationID
public void setJMSCorrelationID(java.lang.String correlationId)
-
setJMSType
public void setJMSType(java.lang.String type)
-
setUUID
public void setUUID(java.lang.String uuid)
-
setPreAcknowledgement
public void setPreAcknowledgement(java.lang.String preack)
-
setNullProperty
public void setNullProperty(java.lang.String name)
-
setStringProperty
public void setStringProperty(java.lang.String name, java.lang.String value) throws TransportEnvelopeException
- Throws:
TransportEnvelopeException
-
setByteArrayProperty
public void setByteArrayProperty(java.lang.String name, byte[] value) throws TransportEnvelopeException
- Throws:
TransportEnvelopeException
-
setBooleanProperty
public void setBooleanProperty(java.lang.String name, boolean value) throws TransportEnvelopeException
- Throws:
TransportEnvelopeException
-
setByteProperty
public void setByteProperty(java.lang.String name, byte value) throws TransportEnvelopeException
- Throws:
TransportEnvelopeException
-
setShortProperty
public void setShortProperty(java.lang.String name, short value) throws TransportEnvelopeException
- Throws:
TransportEnvelopeException
-
setIntProperty
public void setIntProperty(java.lang.String name, int value) throws TransportEnvelopeException
- Throws:
TransportEnvelopeException
-
setLongProperty
public void setLongProperty(java.lang.String name, long value) throws TransportEnvelopeException
- Throws:
TransportEnvelopeException
-
setFloatProperty
public void setFloatProperty(java.lang.String name, float value) throws TransportEnvelopeException
- Throws:
TransportEnvelopeException
-
setDoubleProperty
public void setDoubleProperty(java.lang.String name, double value) throws TransportEnvelopeException
- Throws:
TransportEnvelopeException
-
setText
public void setText(java.lang.String text)
-
getText
public java.lang.String getText()
-
setBytesBody
public void setBytesBody(byte[] value)
-
getBytesBody
public byte[] getBytesBody()
-
setObjectBody
public void setObjectBody(byte[] value)
-
getObjectBody
public byte[] getObjectBody()
-
getNumberOfFields
public int getNumberOfFields()
-
fieldExists
public boolean fieldExists(java.lang.String name)
-
getFieldNames
public java.util.Vector<java.lang.String> getFieldNames()
-
getField
public java.lang.Object getField(java.lang.String name)
-
getField
public java.lang.Object getField(int index)
-
setBooleanField
public void setBooleanField(java.lang.String name, boolean value)
-
setBooleanField
public void setBooleanField(int index, boolean value)
-
setByteField
public void setByteField(java.lang.String name, byte value)
-
setByteField
public void setByteField(int index, byte value)
-
setShortField
public void setShortField(java.lang.String name, short value)
-
setShortField
public void setShortField(int index, short value)
-
setIntField
public void setIntField(java.lang.String name, int value)
-
setIntField
public void setIntField(int index, int value)
-
setLongField
public void setLongField(java.lang.String name, long value)
-
setLongField
public void setLongField(int index, long value)
-
setFloatField
public void setFloatField(java.lang.String name, float value)
-
setFloatField
public void setFloatField(int index, float value)
-
setDoubleField
public void setDoubleField(java.lang.String name, double value)
-
setDoubleField
public void setDoubleField(int index, double value)
-
setCharField
public void setCharField(java.lang.String name, char value)
-
setCharField
public void setCharField(int index, char value)
-
setStringField
public void setStringField(java.lang.String name, java.lang.String value)
-
setStringField
public void setStringField(int index, java.lang.String value)
-
setByteArrayField
public void setByteArrayField(java.lang.String name, byte[] value)
-
setByteArrayField
public void setByteArrayField(int index, byte[] value)
-
-