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 byteTYPE-
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)protectedActiveMQStreamMessage(ClientMessage message, ClientSession session)protectedActiveMQStreamMessage(ClientSession session)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclearBody()voiddoBeforeSend()bytegetType()booleanisBodyAssignableTo(java.lang.Class c)booleanreadBoolean()bytereadByte()intreadBytes(byte[] value)charreadChar()doublereadDouble()floatreadFloat()intreadInt()longreadLong()java.lang.ObjectreadObject()shortreadShort()java.lang.StringreadString()voidreset()voidwriteBoolean(boolean value)voidwriteByte(byte value)voidwriteBytes(byte[] value)voidwriteBytes(byte[] value, int offset, int length)voidwriteChar(char value)voidwriteDouble(double value)voidwriteFloat(float value)voidwriteInt(int value)voidwriteLong(long value)voidwriteObject(java.lang.Object value)voidwriteShort(short value)voidwriteString(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:
getTypein classActiveMQMessage
-
readBoolean
public boolean readBoolean() throws javax.jms.JMSException- Specified by:
readBooleanin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
readByte
public byte readByte() throws javax.jms.JMSException- Specified by:
readBytein interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
readShort
public short readShort() throws javax.jms.JMSException- Specified by:
readShortin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
readChar
public char readChar() throws javax.jms.JMSException- Specified by:
readCharin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
readInt
public int readInt() throws javax.jms.JMSException- Specified by:
readIntin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
readLong
public long readLong() throws javax.jms.JMSException- Specified by:
readLongin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
readFloat
public float readFloat() throws javax.jms.JMSException- Specified by:
readFloatin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
readDouble
public double readDouble() throws javax.jms.JMSException- Specified by:
readDoublein interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
readString
public java.lang.String readString() throws javax.jms.JMSException- Specified by:
readStringin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
readBytes
public int readBytes(byte[] value) throws javax.jms.JMSException- Specified by:
readBytesin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
readObject
public java.lang.Object readObject() throws javax.jms.JMSException- Specified by:
readObjectin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
writeBoolean
public void writeBoolean(boolean value) throws javax.jms.JMSException- Specified by:
writeBooleanin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
writeByte
public void writeByte(byte value) throws javax.jms.JMSException- Specified by:
writeBytein interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
writeShort
public void writeShort(short value) throws javax.jms.JMSException- Specified by:
writeShortin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
writeChar
public void writeChar(char value) throws javax.jms.JMSException- Specified by:
writeCharin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
writeInt
public void writeInt(int value) throws javax.jms.JMSException- Specified by:
writeIntin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
writeLong
public void writeLong(long value) throws javax.jms.JMSException- Specified by:
writeLongin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
writeFloat
public void writeFloat(float value) throws javax.jms.JMSException- Specified by:
writeFloatin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
writeDouble
public void writeDouble(double value) throws javax.jms.JMSException- Specified by:
writeDoublein interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
writeString
public void writeString(java.lang.String value) throws javax.jms.JMSException- Specified by:
writeStringin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
writeBytes
public void writeBytes(byte[] value) throws javax.jms.JMSException- Specified by:
writeBytesin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
writeBytes
public void writeBytes(byte[] value, int offset, int length) throws javax.jms.JMSException- Specified by:
writeBytesin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
writeObject
public void writeObject(java.lang.Object value) throws javax.jms.JMSException- Specified by:
writeObjectin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
reset
public void reset() throws javax.jms.JMSException- Specified by:
resetin interfacejavax.jms.StreamMessage- Throws:
javax.jms.JMSException
-
clearBody
public void clearBody() throws javax.jms.JMSException- Specified by:
clearBodyin interfacejavax.jms.Message- Overrides:
clearBodyin classActiveMQMessage- Throws:
javax.jms.JMSException
-
doBeforeSend
public void doBeforeSend() throws java.lang.Exception- Overrides:
doBeforeSendin classActiveMQMessage- Throws:
java.lang.Exception
-
isBodyAssignableTo
public boolean isBodyAssignableTo(java.lang.Class c)
- Specified by:
isBodyAssignableToin interfacejavax.jms.Message- Overrides:
isBodyAssignableToin classActiveMQMessage
-
-