Package com.webmethods.jms.impl
Class WmBytesMessageImpl
- java.lang.Object
-
- com.webmethods.jms.impl.WmMessageImpl
-
- com.webmethods.jms.impl.WmBytesMessageImpl
-
- All Implemented Interfaces:
WmBytesMessage
,WmMessage
,java.io.Externalizable
,java.io.Serializable
,java.lang.Cloneable
,javax.jms.BytesMessage
,javax.jms.Message
- Direct Known Subclasses:
WmClusterBytesMessageImpl
public class WmBytesMessageImpl extends WmMessageImpl implements WmBytesMessage, java.io.Externalizable
- See Also:
- Serialized Form
-
-
Field Summary
-
Fields inherited from class com.webmethods.jms.impl.WmMessageImpl
_accessLabel, _acknowledged, _compression, _compressionLevel, _compressionManager, _container, _deliveryMode, _destination, _expiration, _messageId, _msgReadOnly, _priority, _readOnlyBody, _readOnlyProperties, _receiveCount, _redelivered, _replyTo, _sequenceNumber, _subscriptionIDs, _timestamp
-
Fields inherited from interface javax.jms.Message
DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE
-
Fields inherited from interface com.webmethods.jms.WmMessage
WM_JMS_CLUSTER_NODES, WM_JMS_CLUSTER_NODES_DELIMITER
-
-
Constructor Summary
Constructors Modifier Constructor Description WmBytesMessageImpl()
protected
WmBytesMessageImpl(TransportMessage container)
protected
WmBytesMessageImpl(javax.jms.BytesMessage sourceMsg)
this constructor is used for Message interoperability
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
clearBody()
Clears out the message body.boolean
equals(java.lang.Object obj)
Checks if two Messages are equallong
getBodyLength()
int
hashCode()
Calculates hash code for this object.protected void
prepareMsgForTransport()
boolean
readBoolean()
byte
readByte()
int
readBytes(byte[] dest)
int
readBytes(byte[] dest, int len)
char
readChar()
double
readDouble()
void
readExternal(java.io.ObjectInput in)
float
readFloat()
int
readInt()
long
readLong()
short
readShort()
int
readUnsignedByte()
int
readUnsignedShort()
java.lang.String
readUTF()
void
reset()
java.lang.String
toString()
void
writeBoolean(boolean value)
void
writeByte(byte value)
void
writeBytes(byte[] value)
void
writeBytes(byte[] value, int offset, int len)
void
writeChar(char value)
void
writeDouble(double value)
void
writeExternal(java.io.ObjectOutput out)
void
writeFloat(float value)
void
writeInt(int value)
void
writeLong(long value)
void
writeObject(java.lang.Object value)
void
writeShort(short value)
void
writeUTF(java.lang.String value)
-
Methods inherited from class com.webmethods.jms.impl.WmMessageImpl
acknowledge, checkMessageBodyReadStatus, checkMessageBodyWriteStatus, checkMessagePropertiesReadStatus, checkMessagePropertiesWriteStatus, checkMessageReadStatus, checkMessageWriteStatus, checkObject, checkString, clearProperties, createMessage, explicitAcknowledge, getAccessLabel, getBooleanProperty, getByteProperty, getCompression, getCompressionLevel, getCompressionRatio, getConsumer, getDestinationId, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSMessageIDHint, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPreAcknowledgement, getPropertyNames, getReceiveCount, getSequenceNumber, getShortProperty, getSize, getStringProperty, getSubscriptionIDs, getTopicName, getTransactionID, getTransportData, getTransportDataLength, getTransportTypeName, getUUID, hashObject, internalToString, isAcknowledged, isPreAcked, negativeAcknowledge, propertyExists, setAccessLabel, setAcknowledged, setBooleanProperty, setByteProperty, setCompression, setCompressionLevel, setConsumer, setDeliveryCount, setDeliveryMode, setDestination, setDestinationId, setDoubleProperty, setExpiration, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSMessageIDHint, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setMessageID, setObjectProperty, setPreAcknowledgement, setPriority, setReadOnly, setReadOnlyBody, setReadOnlyProperties, setReceiveCount, setSequenceNumber, setShortProperty, setStringProperty, setSubscriptionIDs, setTimestamp, setTopicName, setTransactionID, setTransportTypeName, setUUID, xdump
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface javax.jms.Message
acknowledge, clearProperties, getBooleanProperty, getByteProperty, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, propertyExists, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setShortProperty, setStringProperty
-
Methods inherited from interface com.webmethods.jms.WmMessage
explicitAcknowledge, getCompression, getCompressionLevel, getCompressionRatio, getSize, negativeAcknowledge, setAccessLabel, setCompression, setCompressionLevel
-
-
-
-
Constructor Detail
-
WmBytesMessageImpl
public WmBytesMessageImpl() throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
-
WmBytesMessageImpl
protected WmBytesMessageImpl(TransportMessage container)
-
WmBytesMessageImpl
protected WmBytesMessageImpl(javax.jms.BytesMessage sourceMsg) throws javax.jms.JMSException
this constructor is used for Message interoperability
- Throws:
javax.jms.JMSException
-
-
Method Detail
-
getBodyLength
public long getBodyLength() throws javax.jms.JMSException
- Specified by:
getBodyLength
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
readBoolean
public boolean readBoolean() throws javax.jms.JMSException
- Specified by:
readBoolean
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
readByte
public byte readByte() throws javax.jms.JMSException
- Specified by:
readByte
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
readUnsignedByte
public int readUnsignedByte() throws javax.jms.JMSException
- Specified by:
readUnsignedByte
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
readShort
public short readShort() throws javax.jms.JMSException
- Specified by:
readShort
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
readUnsignedShort
public int readUnsignedShort() throws javax.jms.JMSException
- Specified by:
readUnsignedShort
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
readChar
public char readChar() throws javax.jms.JMSException
- Specified by:
readChar
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
readInt
public int readInt() throws javax.jms.JMSException
- Specified by:
readInt
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
readLong
public long readLong() throws javax.jms.JMSException
- Specified by:
readLong
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
readFloat
public float readFloat() throws javax.jms.JMSException
- Specified by:
readFloat
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
readDouble
public double readDouble() throws javax.jms.JMSException
- Specified by:
readDouble
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
readUTF
public java.lang.String readUTF() throws javax.jms.JMSException
- Specified by:
readUTF
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
readBytes
public int readBytes(byte[] dest) throws javax.jms.JMSException
- Specified by:
readBytes
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
readBytes
public int readBytes(byte[] dest, int len) throws javax.jms.JMSException
- Specified by:
readBytes
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
writeBoolean
public void writeBoolean(boolean value) throws javax.jms.JMSException
- Specified by:
writeBoolean
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
writeByte
public void writeByte(byte value) throws javax.jms.JMSException
- Specified by:
writeByte
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
writeShort
public void writeShort(short value) throws javax.jms.JMSException
- Specified by:
writeShort
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
writeChar
public void writeChar(char value) throws javax.jms.JMSException
- Specified by:
writeChar
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
writeInt
public void writeInt(int value) throws javax.jms.JMSException
- Specified by:
writeInt
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
writeLong
public void writeLong(long value) throws javax.jms.JMSException
- Specified by:
writeLong
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
writeFloat
public void writeFloat(float value) throws javax.jms.JMSException
- Specified by:
writeFloat
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
writeDouble
public void writeDouble(double value) throws javax.jms.JMSException
- Specified by:
writeDouble
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
writeUTF
public void writeUTF(java.lang.String value) throws javax.jms.JMSException
- Specified by:
writeUTF
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
writeBytes
public void writeBytes(byte[] value) throws javax.jms.JMSException
- Specified by:
writeBytes
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
writeBytes
public void writeBytes(byte[] value, int offset, int len) throws javax.jms.JMSException
- Specified by:
writeBytes
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
writeObject
public void writeObject(java.lang.Object value) throws javax.jms.JMSException
- Specified by:
writeObject
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
reset
public void reset() throws javax.jms.JMSException
- Specified by:
reset
in interfacejavax.jms.BytesMessage
- Throws:
javax.jms.JMSException
-
clearBody
public void clearBody() throws javax.jms.JMSException
Description copied from class:WmMessageImpl
Clears out the message body. Clearing a message's body does not clear its header values or property entries.If this message body was read-only, calling this method leaves the message body in the same state as an empty body in a newly created message.
- Specified by:
clearBody
in interfacejavax.jms.Message
- Overrides:
clearBody
in classWmMessageImpl
- Throws:
javax.jms.JMSException
- if the JMS provider fails to clear the message body due to some internal error.
-
writeExternal
public void writeExternal(java.io.ObjectOutput out) throws java.io.IOException
- Specified by:
writeExternal
in interfacejava.io.Externalizable
- Overrides:
writeExternal
in classWmMessageImpl
- Throws:
java.io.IOException
- See Also:
Externalizable.writeExternal(java.io.ObjectOutput)
-
readExternal
public void readExternal(java.io.ObjectInput in) throws java.io.IOException, java.lang.ClassNotFoundException
- Specified by:
readExternal
in interfacejava.io.Externalizable
- Overrides:
readExternal
in classWmMessageImpl
- Throws:
java.io.IOException
java.lang.ClassNotFoundException
- See Also:
Externalizable.readExternal(java.io.ObjectInput)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classWmMessageImpl
-
equals
public boolean equals(java.lang.Object obj)
Checks if two Messages are equal- Overrides:
equals
in classWmMessageImpl
- See Also:
Object.equals(Object)
-
hashCode
public int hashCode()
Calculates hash code for this object.- Overrides:
hashCode
in classWmMessageImpl
- See Also:
Object.hashCode()
-
prepareMsgForTransport
protected void prepareMsgForTransport()
- Overrides:
prepareMsgForTransport
in classWmMessageImpl
-
-