Class CoreStreamMessageWrapper
java.lang.Object
org.apache.activemq.artemis.protocol.amqp.converter.coreWrapper.CoreMessageWrapper
org.apache.activemq.artemis.protocol.amqp.converter.coreWrapper.CoreStreamMessageWrapper
-
Field Summary
FieldsFields inherited from class CoreMessageWrapper
message -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidorg.apache.qpid.proton.amqp.messaging.SectioncreateAMQPSection(Map<org.apache.qpid.proton.amqp.Symbol, Object> maMap, org.apache.qpid.proton.amqp.messaging.Properties properties) voiddecode()voidencode()Encode the body into the internal messagebooleanbytereadByte()intreadBytes(byte[] value) charreadChar()doublefloatintreadInt()longreadLong()shortvoidreset()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(Object value) voidwriteShort(short value) voidwriteString(String value) Methods inherited from class CoreMessageWrapper
clearProperties, getBooleanProperty, getByteProperty, getDestination, getDoubleProperty, getExpiration, getFloatProperty, getInnerMessage, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSMessageID, getJMSPriority, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getOrignalEncoding, getPropertyNames, getReadBodyBuffer, getShortProperty, getStringProperty, getWriteBodyBuffer, propertyExists, setBooleanProperty, setByteProperty, setDeliveryMode, setDestination, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setShortProperty, setStringProperty, wrap
-
Field Details
-
TYPE
public static final byte TYPE- See Also:
-
-
Constructor Details
-
CoreStreamMessageWrapper
-
-
Method Details
-
createAMQPSection
public org.apache.qpid.proton.amqp.messaging.Section createAMQPSection(Map<org.apache.qpid.proton.amqp.Symbol, Object> maMap, org.apache.qpid.proton.amqp.messaging.Properties properties) throws ConversionException - Overrides:
createAMQPSectionin classCoreMessageWrapper- Throws:
ConversionException
-
readBoolean
-
readByte
-
readShort
-
readChar
-
readInt
-
readLong
-
readFloat
-
readDouble
-
readString
-
readBytes
-
readObject
-
writeBoolean
public void writeBoolean(boolean value) -
writeByte
public void writeByte(byte value) -
writeShort
public void writeShort(short value) -
writeChar
public void writeChar(char value) -
writeInt
public void writeInt(int value) -
writeLong
public void writeLong(long value) -
writeFloat
public void writeFloat(float value) -
writeDouble
public void writeDouble(double value) -
writeString
-
writeBytes
public void writeBytes(byte[] value) -
writeBytes
public void writeBytes(byte[] value, int offset, int length) -
writeObject
- Throws:
ConversionException
-
reset
public void reset() -
clearBody
public void clearBody()- Overrides:
clearBodyin classCoreMessageWrapper
-
decode
public void decode()- Overrides:
decodein classCoreMessageWrapper
-
encode
public void encode()Description copied from class:CoreMessageWrapperEncode the body into the internal message- Overrides:
encodein classCoreMessageWrapper
-