public final class ActiveMQStreamMessage extends ActiveMQMessage implements javax.jms.StreamMessage
| Modifier and Type | Field and Description |
|---|---|
static byte |
TYPE |
message, propertiesReadOnly, readOnly| Modifier | Constructor and Description |
|---|---|
|
ActiveMQStreamMessage() |
protected |
ActiveMQStreamMessage(ClientMessage message,
ClientSession session) |
protected |
ActiveMQStreamMessage(ClientSession session) |
|
ActiveMQStreamMessage(javax.jms.StreamMessage foreign,
ClientSession session) |
| Modifier and Type | Method and Description |
|---|---|
void |
clearBody() |
void |
doBeforeSend() |
byte |
getType() |
boolean |
isBodyAssignableTo(Class c) |
boolean |
readBoolean() |
byte |
readByte() |
int |
readBytes(byte[] value) |
char |
readChar() |
double |
readDouble() |
float |
readFloat() |
int |
readInt() |
long |
readLong() |
Object |
readObject() |
short |
readShort() |
String |
readString() |
void |
reset() |
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, checkBuffer, checkRead, checkWrite, clearProperties, coreCompositeTypeToJMSCompositeType, coreMaptoJMSMap, createMessage, createMessage, doBeforeReceive, getBody, getBodyInternal, getBooleanProperty, getByteProperty, getCoreMessage, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDeliveryTime, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, hasNoBody, propertyExists, resetMessageID, saveToOutputStream, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIndividualAcknowledge, setInputStream, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDeliveryTime, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setOutputStream, setShortProperty, setStringProperty, toString, waitCompletionOnStreamclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitacknowledge, clearProperties, getBody, getBooleanProperty, getByteProperty, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDeliveryTime, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, propertyExists, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDeliveryTime, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setShortProperty, setStringPropertypublic static final byte TYPE
protected ActiveMQStreamMessage(ClientSession session)
protected ActiveMQStreamMessage(ClientMessage message, ClientSession session)
public ActiveMQStreamMessage(javax.jms.StreamMessage foreign,
ClientSession session)
throws javax.jms.JMSException
javax.jms.JMSExceptionpublic ActiveMQStreamMessage()
public byte getType()
getType in class ActiveMQMessagepublic boolean readBoolean()
throws javax.jms.JMSException
readBoolean in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic byte readByte()
throws javax.jms.JMSException
readByte in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic short readShort()
throws javax.jms.JMSException
readShort in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic char readChar()
throws javax.jms.JMSException
readChar in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic int readInt()
throws javax.jms.JMSException
readInt in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic long readLong()
throws javax.jms.JMSException
readLong in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic float readFloat()
throws javax.jms.JMSException
readFloat in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic double readDouble()
throws javax.jms.JMSException
readDouble in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic String readString() throws javax.jms.JMSException
readString in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic int readBytes(byte[] value)
throws javax.jms.JMSException
readBytes in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic Object readObject() throws javax.jms.JMSException
readObject in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic void writeBoolean(boolean value)
throws javax.jms.JMSException
writeBoolean in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic void writeByte(byte value)
throws javax.jms.JMSException
writeByte in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic void writeShort(short value)
throws javax.jms.JMSException
writeShort in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic void writeChar(char value)
throws javax.jms.JMSException
writeChar in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic void writeInt(int value)
throws javax.jms.JMSException
writeInt in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic void writeLong(long value)
throws javax.jms.JMSException
writeLong in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic void writeFloat(float value)
throws javax.jms.JMSException
writeFloat in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic void writeDouble(double value)
throws javax.jms.JMSException
writeDouble in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic void writeString(String value) throws javax.jms.JMSException
writeString in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic void writeBytes(byte[] value)
throws javax.jms.JMSException
writeBytes in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic void writeBytes(byte[] value,
int offset,
int length)
throws javax.jms.JMSException
writeBytes in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic void writeObject(Object value) throws javax.jms.JMSException
writeObject in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic void reset()
throws javax.jms.JMSException
reset in interface javax.jms.StreamMessagejavax.jms.JMSExceptionpublic void clearBody()
throws javax.jms.JMSException
clearBody in interface javax.jms.MessageclearBody in class ActiveMQMessagejavax.jms.JMSExceptionpublic void doBeforeSend()
throws Exception
doBeforeSend in class ActiveMQMessageExceptionpublic boolean isBodyAssignableTo(Class c)
isBodyAssignableTo in interface javax.jms.MessageisBodyAssignableTo in class ActiveMQMessageCopyright © 2018 The Apache Software Foundation. All rights reserved.