|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.joram.client.jms.Message
org.objectweb.joram.client.jms.StreamMessage
public final class StreamMessage
Implements the javax.jms.StreamMessage
interface.
Field Summary | |
---|---|
private int |
available
|
private static int |
BOOLEAN
|
private static int |
BYTE
|
private static int |
BYTES
|
private static int |
CHAR
|
private static int |
DOUBLE
|
private boolean |
firstTimeBytesRead
|
private static int |
FLOAT
|
private java.io.DataInputStream |
inputStream
The stream for reading the data. |
private static int |
INT
|
private static int |
LONG
|
private static int |
NULL
|
private java.io.ByteArrayOutputStream |
outputBuffer
The array in which the written data is buffered. |
private java.io.DataOutputStream |
outputStream
The stream in which body data is written. |
private boolean |
prepared
true if the message has been sent since its last modification. |
private static int |
SHORT
|
private static int |
STRING
|
Fields inherited from class org.objectweb.joram.client.jms.Message |
---|
jmsDest, logger, momMsg, propertiesRO, RObody, session |
Fields inherited from interface javax.jms.Message |
---|
DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE |
Constructor Summary | |
---|---|
StreamMessage()
Instantiates a bright new StreamMessage . |
|
StreamMessage(Session session,
Message momMsg)
Instantiates a StreamMessage wrapping a consumed
MOM message containing a stream of bytes. |
Method Summary | |
---|---|
void |
clearBody()
API method. |
protected void |
prepare()
Method actually preparing the message for sending by transferring the local body into the wrapped MOM message. |
private void |
prepareWrite()
Internal method called before each writing operation. |
boolean |
readBoolean()
API method. |
byte |
readByte()
API method. |
int |
readBytes(byte[] bytes)
API method. |
char |
readChar()
API method. |
double |
readDouble()
API method. |
float |
readFloat()
API method. |
int |
readInt()
API method. |
long |
readLong()
API method. |
java.lang.Object |
readObject()
API method. |
short |
readShort()
API method. |
java.lang.String |
readString()
API method. |
void |
reset()
API method. |
void |
writeBoolean(boolean value)
API method. |
void |
writeByte(byte value)
API method. |
void |
writeBytes(byte[] value)
API method. |
void |
writeBytes(byte[] value,
int offset,
int length)
API method. |
void |
writeChar(char value)
API method. |
void |
writeDouble(double value)
API method. |
void |
writeFloat(float value)
API method. |
void |
writeInt(int value)
API method. |
void |
writeLong(long value)
API method. |
void |
writeObject(java.lang.Object value)
API method. |
void |
writeShort(short value)
API method. |
void |
writeString(java.lang.String value)
API method. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, 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 |
Field Detail |
---|
private transient java.io.ByteArrayOutputStream outputBuffer
private transient java.io.DataOutputStream outputStream
private transient java.io.DataInputStream inputStream
private transient boolean prepared
true
if the message has been sent since its last modification.
private transient int available
private transient boolean firstTimeBytesRead
private static final int SHORT
private static final int CHAR
private static final int INT
private static final int LONG
private static final int FLOAT
private static final int DOUBLE
private static final int BOOLEAN
private static final int STRING
private static final int BYTE
private static final int BYTES
private static final int NULL
Constructor Detail |
---|
StreamMessage() throws javax.jms.JMSException
StreamMessage
.
javax.jms.JMSException
- In case of an error while creating the output
stream.StreamMessage(Session session, Message momMsg) throws javax.jms.JMSException
StreamMessage
wrapping a consumed
MOM message containing a stream of bytes.
session
- The consuming session.momMsg
- The MOM message to wrap.
javax.jms.JMSException
- In case of an error while creating the input
stream.Method Detail |
---|
public void clearBody() throws javax.jms.JMSException
clearBody
in interface javax.jms.Message
clearBody
in class Message
javax.jms.JMSException
- In case of an error while closing the input or
output streams.private void prepareWrite() throws javax.jms.JMSException
javax.jms.MessageNotWriteableException
- If the message body is READ only.
javax.jms.JMSException
- If the stream could not be prepared for the
writing operation.public void writeBoolean(boolean value) throws javax.jms.JMSException
writeBoolean
in interface javax.jms.StreamMessage
javax.jms.MessageNotWriteableException
- If the message body is read-only.
javax.jms.JMSException
- If the value could not be written on the stream.public void writeByte(byte value) throws javax.jms.JMSException
writeByte
in interface javax.jms.StreamMessage
javax.jms.MessageNotWriteableException
- If the message body is read-only.
javax.jms.JMSException
- If the value could not be written on the stream.public void writeBytes(byte[] value) throws javax.jms.JMSException
writeBytes
in interface javax.jms.StreamMessage
javax.jms.MessageNotWriteableException
- If the message body is read-only.
javax.jms.JMSException
- If the value could not be written on the stream.public void writeBytes(byte[] value, int offset, int length) throws javax.jms.JMSException
writeBytes
in interface javax.jms.StreamMessage
javax.jms.MessageNotWriteableException
- If the message body is read-only.
javax.jms.JMSException
- If the value could not be written on the stream.public void writeChar(char value) throws javax.jms.JMSException
writeChar
in interface javax.jms.StreamMessage
javax.jms.MessageNotWriteableException
- If the message body is read-only.
javax.jms.JMSException
- If the value could not be written on the stream.public void writeDouble(double value) throws javax.jms.JMSException
writeDouble
in interface javax.jms.StreamMessage
javax.jms.MessageNotWriteableException
- If the message body is read-only.
javax.jms.JMSException
- If the value could not be written on the stream.public void writeFloat(float value) throws javax.jms.JMSException
writeFloat
in interface javax.jms.StreamMessage
javax.jms.MessageNotWriteableException
- If the message body is read-only.
javax.jms.JMSException
- If the value could not be written on the stream.public void writeInt(int value) throws javax.jms.JMSException
writeInt
in interface javax.jms.StreamMessage
javax.jms.MessageNotWriteableException
- If the message body is read-only.
javax.jms.JMSException
- If the value could not be written on the stream.public void writeLong(long value) throws javax.jms.JMSException
writeLong
in interface javax.jms.StreamMessage
javax.jms.MessageNotWriteableException
- If the message body is read-only.
javax.jms.JMSException
- If the value could not be written on the stream.public void writeShort(short value) throws javax.jms.JMSException
writeShort
in interface javax.jms.StreamMessage
javax.jms.MessageNotWriteableException
- If the message body is read-only.
javax.jms.JMSException
- If the value could not be written on the stream.public void writeString(java.lang.String value) throws javax.jms.JMSException
writeString
in interface javax.jms.StreamMessage
javax.jms.MessageNotWriteableException
- If the message body is read-only.
javax.jms.JMSException
- If the value could not be written on the stream.public void writeObject(java.lang.Object value) throws javax.jms.JMSException
writeObject
in interface javax.jms.StreamMessage
javax.jms.MessageNotWriteableException
- If the message body is read-only.
javax.jms.MessageFormatException
- If the value type is invalid.
javax.jms.JMSException
- If the value could not be written on the stream.public boolean readBoolean() throws javax.jms.JMSException
readBoolean
in interface javax.jms.StreamMessage
javax.jms.MessageNotReadableException
- If the message body is write-only.
javax.jms.MessageFormatException
- If reading the expected type is
not possible.
javax.jms.MessageEOFException
- Unexpected end of bytes array.
javax.jms.JMSException
- internal errorpublic byte readByte() throws javax.jms.JMSException
readByte
in interface javax.jms.StreamMessage
javax.jms.MessageNotReadableException
- If the message body is write-only.
javax.jms.MessageFormatException
- If reading the expected type is
not possible.
javax.jms.MessageEOFException
- Unexpected end of bytes array.
javax.jms.JMSException
- internal errorpublic short readShort() throws javax.jms.JMSException
readShort
in interface javax.jms.StreamMessage
javax.jms.MessageNotReadableException
- If the message body is write-only.
javax.jms.MessageFormatException
- If reading the expected type is
not possible.
javax.jms.MessageEOFException
- Unexpected end of bytes array.
javax.jms.JMSException
- internal errorpublic char readChar() throws javax.jms.JMSException
readChar
in interface javax.jms.StreamMessage
javax.jms.MessageNotReadableException
- If the message body is write-only.
javax.jms.MessageFormatException
- If reading the expected type is
not possible.
javax.jms.MessageEOFException
- Unexpected end of bytes array.
javax.jms.JMSException
- internal errorpublic int readInt() throws javax.jms.JMSException
readInt
in interface javax.jms.StreamMessage
javax.jms.MessageNotReadableException
- If the message body is write-only.
javax.jms.MessageFormatException
- If reading the expected type is
not possible.
javax.jms.MessageEOFException
- Unexpected end of bytes array.
javax.jms.JMSException
- internal errorpublic long readLong() throws javax.jms.JMSException
readLong
in interface javax.jms.StreamMessage
javax.jms.MessageNotReadableException
- If the message body is write-only.
javax.jms.MessageFormatException
- If reading the expected type is
not possible.
javax.jms.MessageEOFException
- Unexpected end of bytes array.
javax.jms.JMSException
- internal errorpublic float readFloat() throws javax.jms.JMSException
readFloat
in interface javax.jms.StreamMessage
javax.jms.MessageNotReadableException
- If the message body is write-only.
javax.jms.MessageFormatException
- If reading the expected type is
not possible.
javax.jms.MessageEOFException
- Unexpected end of bytes array.
javax.jms.JMSException
- internal errorpublic double readDouble() throws javax.jms.JMSException
readDouble
in interface javax.jms.StreamMessage
javax.jms.MessageNotReadableException
- If the message body is write-only.
javax.jms.MessageFormatException
- If reading the expected type is
not possible.
javax.jms.MessageEOFException
- Unexpected end of bytes array.
javax.jms.JMSException
- internal errorpublic int readBytes(byte[] bytes) throws javax.jms.JMSException
readBytes
in interface javax.jms.StreamMessage
javax.jms.MessageNotReadableException
- If the message body is write-only.
javax.jms.MessageFormatException
- If reading the expected type is
not possible.
javax.jms.MessageEOFException
- Unexpected end of bytes array.
javax.jms.JMSException
- internal errorpublic java.lang.String readString() throws javax.jms.JMSException
readString
in interface javax.jms.StreamMessage
javax.jms.MessageNotReadableException
- If the message body is write-only.
javax.jms.MessageFormatException
- If reading the expected type is
not possible.
javax.jms.MessageEOFException
- Unexpected end of bytes array.
javax.jms.JMSException
- internal errorpublic java.lang.Object readObject() throws javax.jms.JMSException
readObject
in interface javax.jms.StreamMessage
javax.jms.MessageNotReadableException
- If the message body is write-only.
javax.jms.MessageFormatException
- If reading the body is
not possible.
javax.jms.MessageEOFException
- Unexpected end of bytes array.
javax.jms.JMSException
- internal errorpublic void reset() throws javax.jms.JMSException
reset
in interface javax.jms.StreamMessage
javax.jms.JMSException
- If an error occurs while closing the output
stream.protected void prepare() throws javax.jms.JMSException
prepare
in class Message
javax.jms.MessageFormatException
- If an error occurs while serializing.
javax.jms.JMSException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |