public class JmsStreamMessage extends JmsMessage implements javax.jms.StreamMessage
acknowledgeCallback, connection, readOnlyBody, readOnlyProperties, validatePropertyNames
Constructor and Description |
---|
JmsStreamMessage(JmsStreamMessageFacade facade) |
Modifier and Type | Method and Description |
---|---|
void |
clearBody() |
JmsStreamMessage |
copy() |
void |
onSend(long producerTtl)
Used to trigger processing required to place the message in a state where it is
ready to be written to the wire.
|
boolean |
readBoolean() |
byte |
readByte() |
int |
readBytes(byte[] target) |
char |
readChar() |
double |
readDouble() |
float |
readFloat() |
int |
readInt() |
long |
readLong() |
Object |
readObject() |
short |
readShort() |
String |
readString() |
void |
reset() |
String |
toString() |
void |
writeBoolean(boolean value) |
void |
writeByte(byte value) |
void |
writeBytes(byte[] value) |
void |
writeBytes(byte[] value,
int offset,
int length) |
void |
writeChar(char value) |
void |
writeDouble(double value) |
void |
writeFloat(float value) |
void |
writeInt(int value) |
void |
writeLong(long value) |
void |
writeObject(Object value) |
void |
writeShort(short value) |
void |
writeString(String value) |
acknowledge, checkReadOnlyBody, checkReadOnlyProperties, checkWriteOnlyBody, clearProperties, copy, equals, getAcknowledgeCallback, getAllPropertyNames, getBooleanProperty, getByteProperty, getConnection, getDoubleProperty, getFacade, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, hashCode, isExpired, isReadOnlyBody, isReadOnlyProperties, isValidatePropertyNames, onDispatch, propertyExists, setAcknowledgeCallback, setBooleanProperty, setByteProperty, setConnection, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setReadOnlyBody, setReadOnlyProperties, setShortProperty, setStringProperty, setValidatePropertyNames
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
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
public JmsStreamMessage(JmsStreamMessageFacade facade)
public JmsStreamMessage copy() throws javax.jms.JMSException
copy
in class JmsMessage
javax.jms.JMSException
public void onSend(long producerTtl) throws javax.jms.JMSException
JmsMessage
onSend
in class JmsMessage
producerTtl
- the time to live value that the producer was configured with at send time.javax.jms.JMSException
- if an error occurs while preparing the message for send.public void clearBody() throws javax.jms.JMSException
clearBody
in interface javax.jms.Message
clearBody
in class JmsMessage
javax.jms.JMSException
public boolean readBoolean() throws javax.jms.JMSException
readBoolean
in interface javax.jms.StreamMessage
javax.jms.JMSException
public byte readByte() throws javax.jms.JMSException
readByte
in interface javax.jms.StreamMessage
javax.jms.JMSException
public short readShort() throws javax.jms.JMSException
readShort
in interface javax.jms.StreamMessage
javax.jms.JMSException
public char readChar() throws javax.jms.JMSException
readChar
in interface javax.jms.StreamMessage
javax.jms.JMSException
public int readInt() throws javax.jms.JMSException
readInt
in interface javax.jms.StreamMessage
javax.jms.JMSException
public long readLong() throws javax.jms.JMSException
readLong
in interface javax.jms.StreamMessage
javax.jms.JMSException
public float readFloat() throws javax.jms.JMSException
readFloat
in interface javax.jms.StreamMessage
javax.jms.JMSException
public double readDouble() throws javax.jms.JMSException
readDouble
in interface javax.jms.StreamMessage
javax.jms.JMSException
public String readString() throws javax.jms.JMSException
readString
in interface javax.jms.StreamMessage
javax.jms.JMSException
public int readBytes(byte[] target) throws javax.jms.JMSException
readBytes
in interface javax.jms.StreamMessage
javax.jms.JMSException
public Object readObject() throws javax.jms.JMSException
readObject
in interface javax.jms.StreamMessage
javax.jms.JMSException
public void writeBoolean(boolean value) throws javax.jms.JMSException
writeBoolean
in interface javax.jms.StreamMessage
javax.jms.JMSException
public void writeByte(byte value) throws javax.jms.JMSException
writeByte
in interface javax.jms.StreamMessage
javax.jms.JMSException
public void writeShort(short value) throws javax.jms.JMSException
writeShort
in interface javax.jms.StreamMessage
javax.jms.JMSException
public void writeChar(char value) throws javax.jms.JMSException
writeChar
in interface javax.jms.StreamMessage
javax.jms.JMSException
public void writeInt(int value) throws javax.jms.JMSException
writeInt
in interface javax.jms.StreamMessage
javax.jms.JMSException
public void writeLong(long value) throws javax.jms.JMSException
writeLong
in interface javax.jms.StreamMessage
javax.jms.JMSException
public void writeFloat(float value) throws javax.jms.JMSException
writeFloat
in interface javax.jms.StreamMessage
javax.jms.JMSException
public void writeDouble(double value) throws javax.jms.JMSException
writeDouble
in interface javax.jms.StreamMessage
javax.jms.JMSException
public void writeString(String value) throws javax.jms.JMSException
writeString
in interface javax.jms.StreamMessage
javax.jms.JMSException
public void writeBytes(byte[] value) throws javax.jms.JMSException
writeBytes
in interface javax.jms.StreamMessage
javax.jms.JMSException
public void writeBytes(byte[] value, int offset, int length) throws javax.jms.JMSException
writeBytes
in interface javax.jms.StreamMessage
javax.jms.JMSException
public void writeObject(Object value) throws javax.jms.JMSException
writeObject
in interface javax.jms.StreamMessage
javax.jms.JMSException
public void reset() throws javax.jms.JMSException
reset
in interface javax.jms.StreamMessage
javax.jms.JMSException
public String toString()
toString
in class JmsMessage
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.