Class ActiveMQStreamMessage
- java.lang.Object
-
- org.apache.activemq.artemis.jms.client.ActiveMQMessage
-
- org.apache.activemq.artemis.jms.client.ActiveMQStreamMessage
-
- All Implemented Interfaces:
javax.jms.Message
,javax.jms.StreamMessage
- Direct Known Subclasses:
ActiveMQStreamCompatibleMessage
public class ActiveMQStreamMessage extends ActiveMQMessage implements javax.jms.StreamMessage
ActiveMQ Artemis implementation of a JMS StreamMessage.
-
-
Field Summary
Fields Modifier and Type Field Description static byte
TYPE
-
Fields inherited from class org.apache.activemq.artemis.jms.client.ActiveMQMessage
message, OLD_QUEUE_QUALIFIED_PREFIX, OLD_TEMP_QUEUE_QUALIFED_PREFIX, OLD_TEMP_TOPIC_QUALIFED_PREFIX, OLD_TOPIC_QUALIFIED_PREFIX, propertiesReadOnly, readOnly, replyTo
-
-
Constructor Summary
Constructors Modifier Constructor Description ActiveMQStreamMessage()
ActiveMQStreamMessage(javax.jms.StreamMessage foreign, ClientSession session)
protected
ActiveMQStreamMessage(ClientMessage message, ClientSession session)
protected
ActiveMQStreamMessage(ClientSession session)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
clearBody()
void
doBeforeSend()
byte
getType()
boolean
isBodyAssignableTo(java.lang.Class c)
boolean
readBoolean()
byte
readByte()
int
readBytes(byte[] value)
char
readChar()
double
readDouble()
float
readFloat()
int
readInt()
long
readLong()
java.lang.Object
readObject()
short
readShort()
java.lang.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(java.lang.Object value)
void
writeShort(short value)
void
writeString(java.lang.String value)
-
Methods inherited from class org.apache.activemq.artemis.jms.client.ActiveMQMessage
acknowledge, checkBuffer, checkPrefix, checkPrefixStr, 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, prefixOf, propertyExists, resetMessageID, saveToOutputStream, setBooleanProperty, setByteProperty, setClientAcknowledge, setDoubleProperty, setFloatProperty, setIndividualAcknowledge, setInputStream, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDeliveryTime, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setOutputStream, setShortProperty, setStringProperty, toString, waitCompletionOnStream
-
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, 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, setStringProperty
-
-
-
-
Field Detail
-
TYPE
public static final byte TYPE
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
ActiveMQStreamMessage
protected ActiveMQStreamMessage(ClientSession session)
-
ActiveMQStreamMessage
protected ActiveMQStreamMessage(ClientMessage message, ClientSession session)
-
ActiveMQStreamMessage
public ActiveMQStreamMessage(javax.jms.StreamMessage foreign, ClientSession session) throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
-
ActiveMQStreamMessage
public ActiveMQStreamMessage()
-
-
Method Detail
-
getType
public byte getType()
- Overrides:
getType
in classActiveMQMessage
-
readBoolean
public boolean readBoolean() throws javax.jms.JMSException
- Specified by:
readBoolean
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
readByte
public byte readByte() throws javax.jms.JMSException
- Specified by:
readByte
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
readShort
public short readShort() throws javax.jms.JMSException
- Specified by:
readShort
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
readChar
public char readChar() throws javax.jms.JMSException
- Specified by:
readChar
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
readInt
public int readInt() throws javax.jms.JMSException
- Specified by:
readInt
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
readLong
public long readLong() throws javax.jms.JMSException
- Specified by:
readLong
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
readFloat
public float readFloat() throws javax.jms.JMSException
- Specified by:
readFloat
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
readDouble
public double readDouble() throws javax.jms.JMSException
- Specified by:
readDouble
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
readString
public java.lang.String readString() throws javax.jms.JMSException
- Specified by:
readString
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
readBytes
public int readBytes(byte[] value) throws javax.jms.JMSException
- Specified by:
readBytes
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
readObject
public java.lang.Object readObject() throws javax.jms.JMSException
- Specified by:
readObject
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
writeBoolean
public void writeBoolean(boolean value) throws javax.jms.JMSException
- Specified by:
writeBoolean
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
writeByte
public void writeByte(byte value) throws javax.jms.JMSException
- Specified by:
writeByte
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
writeShort
public void writeShort(short value) throws javax.jms.JMSException
- Specified by:
writeShort
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
writeChar
public void writeChar(char value) throws javax.jms.JMSException
- Specified by:
writeChar
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
writeInt
public void writeInt(int value) throws javax.jms.JMSException
- Specified by:
writeInt
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
writeLong
public void writeLong(long value) throws javax.jms.JMSException
- Specified by:
writeLong
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
writeFloat
public void writeFloat(float value) throws javax.jms.JMSException
- Specified by:
writeFloat
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
writeDouble
public void writeDouble(double value) throws javax.jms.JMSException
- Specified by:
writeDouble
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
writeString
public void writeString(java.lang.String value) throws javax.jms.JMSException
- Specified by:
writeString
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
writeBytes
public void writeBytes(byte[] value) throws javax.jms.JMSException
- Specified by:
writeBytes
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
writeBytes
public void writeBytes(byte[] value, int offset, int length) throws javax.jms.JMSException
- Specified by:
writeBytes
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
writeObject
public void writeObject(java.lang.Object value) throws javax.jms.JMSException
- Specified by:
writeObject
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
reset
public void reset() throws javax.jms.JMSException
- Specified by:
reset
in interfacejavax.jms.StreamMessage
- Throws:
javax.jms.JMSException
-
clearBody
public void clearBody() throws javax.jms.JMSException
- Specified by:
clearBody
in interfacejavax.jms.Message
- Overrides:
clearBody
in classActiveMQMessage
- Throws:
javax.jms.JMSException
-
doBeforeSend
public void doBeforeSend() throws java.lang.Exception
- Overrides:
doBeforeSend
in classActiveMQMessage
- Throws:
java.lang.Exception
-
isBodyAssignableTo
public boolean isBodyAssignableTo(java.lang.Class c)
- Specified by:
isBodyAssignableTo
in interfacejavax.jms.Message
- Overrides:
isBodyAssignableTo
in classActiveMQMessage
-
-