org.jboss.jms.message
Class JBossStreamMessage
java.lang.Object
org.jboss.messaging.core.impl.message.MessageSupport
org.jboss.jms.message.JBossMessage
org.jboss.jms.message.JBossStreamMessage
- All Implemented Interfaces:
- java.io.Serializable, javax.jms.StreamMessage, Message, Streamable
public class JBossStreamMessage
- extends JBossMessage
- implements javax.jms.StreamMessage
This class implements javax.jms.StreamMessage.
- Version:
- $Revision: 3190 $
$Id: JBossStreamMessage.java 3190 2007-10-15 13:03:24Z timfox $
- Author:
- Norbert Lataille (Norbert.Lataille@m4x.org), Adrian Brock, Tim Fox, Ovidiu Feodorov
- See Also:
- Serialized Form
Fields inherited from interface javax.jms.Message |
DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE |
Methods inherited from class org.jboss.jms.message.JBossMessage |
acknowledge, clearProperties, createThinDelegate, dump, getBooleanProperty, getByteProperty, getConnectionID, getDoubleProperty, getFloatProperty, getHeaders, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSProperties, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getOriginalSuckerDestination, getPropertyNames, getScheduledDeliveryTime, getShortProperty, getStringProperty, isCorrelationIDBytes, isReference, propertyExists, read, setBooleanProperty, setByteProperty, setConnectionID, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setMessageId, setObjectProperty, setOriginalSuckerDestination, setShortProperty, setStringProperty, toString, write |
Methods inherited from class org.jboss.messaging.core.impl.message.MessageSupport |
containsHeader, createReference, doWriteObject, equals, getExpiration, getHeader, getMessageID, getPayload, getPayloadAsByteArray, getPriority, getTimestamp, hashCode, isExpired, isPersisted, isReliable, putHeader, readPayload, removeHeader, setExpiration, setPayload, setPersisted, setPriority |
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 |
TYPE
public static final byte TYPE
- See Also:
- Constant Field Values
position
protected transient int position
offset
protected transient int offset
size
protected int size
JBossStreamMessage
public JBossStreamMessage()
- Only deserialization should use this constructor directory
JBossStreamMessage
public JBossStreamMessage(long messageID)
JBossStreamMessage
public JBossStreamMessage(long messageID,
boolean reliable,
long expiration,
long timestamp,
byte priority,
java.util.Map coreHeaders,
byte[] payloadAsByteArray)
JBossStreamMessage
public JBossStreamMessage(JBossStreamMessage other)
- Make a shallow copy of another JBossStreamMessage
- Parameters:
other
-
JBossStreamMessage
public JBossStreamMessage(javax.jms.StreamMessage foreign,
long id)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getType
public byte getType()
- Specified by:
getType
in interface Message
- Overrides:
getType
in class JBossMessage
- Returns:
- the type of the message
doBeforeSend
public void doBeforeSend()
throws javax.jms.JMSException
- Overrides:
doBeforeSend
in class JBossMessage
- Throws:
javax.jms.JMSException
doBeforeReceive
public void doBeforeReceive()
throws javax.jms.JMSException
- Overrides:
doBeforeReceive
in class JBossMessage
- Throws:
javax.jms.JMSException
copyPayload
public void copyPayload(java.lang.Object other)
throws javax.jms.JMSException
- Overrides:
copyPayload
in class JBossMessage
- Throws:
javax.jms.JMSException
readBoolean
public boolean readBoolean()
throws javax.jms.JMSException
- Specified by:
readBoolean
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
readByte
public byte readByte()
throws javax.jms.JMSException
- Specified by:
readByte
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
readShort
public short readShort()
throws javax.jms.JMSException
- Specified by:
readShort
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
readChar
public char readChar()
throws javax.jms.JMSException
- Specified by:
readChar
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
readInt
public int readInt()
throws javax.jms.JMSException
- Specified by:
readInt
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
readLong
public long readLong()
throws javax.jms.JMSException
- Specified by:
readLong
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
readFloat
public float readFloat()
throws javax.jms.JMSException
- Specified by:
readFloat
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
readDouble
public double readDouble()
throws javax.jms.JMSException
- Specified by:
readDouble
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
readString
public java.lang.String readString()
throws javax.jms.JMSException
- Specified by:
readString
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
readBytes
public int readBytes(byte[] value)
throws javax.jms.JMSException
- Specified by:
readBytes
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
readObject
public java.lang.Object readObject()
throws javax.jms.JMSException
- Specified by:
readObject
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
writeBoolean
public void writeBoolean(boolean value)
throws javax.jms.JMSException
- Specified by:
writeBoolean
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
writeByte
public void writeByte(byte value)
throws javax.jms.JMSException
- Specified by:
writeByte
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
writeShort
public void writeShort(short value)
throws javax.jms.JMSException
- Specified by:
writeShort
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
writeChar
public void writeChar(char value)
throws javax.jms.JMSException
- Specified by:
writeChar
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
writeInt
public void writeInt(int value)
throws javax.jms.JMSException
- Specified by:
writeInt
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
writeLong
public void writeLong(long value)
throws javax.jms.JMSException
- Specified by:
writeLong
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
writeFloat
public void writeFloat(float value)
throws javax.jms.JMSException
- Specified by:
writeFloat
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
writeDouble
public void writeDouble(double value)
throws javax.jms.JMSException
- Specified by:
writeDouble
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
writeString
public void writeString(java.lang.String value)
throws javax.jms.JMSException
- Specified by:
writeString
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
writeBytes
public void writeBytes(byte[] value)
throws javax.jms.JMSException
- Specified by:
writeBytes
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
writeBytes
public void writeBytes(byte[] value,
int offset,
int length)
throws javax.jms.JMSException
- Specified by:
writeBytes
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
writeObject
public void writeObject(java.lang.Object value)
throws javax.jms.JMSException
- Specified by:
writeObject
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
reset
public void reset()
throws javax.jms.JMSException
- Specified by:
reset
in interface javax.jms.StreamMessage
- Throws:
javax.jms.JMSException
clearBody
public void clearBody()
throws javax.jms.JMSException
- Overrides:
clearBody
in class JBossMessage
- Throws:
javax.jms.JMSException
doCopy
public JBossMessage doCopy()
- Overrides:
doCopy
in class JBossMessage
Copyright © 2006 JBoss Inc. All Rights Reserved.