Class CoreStreamMessageWrapper

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.converter.coreWrapper.CoreMessageWrapper

org.apache.activemq.artemis.protocol.amqp.converter.coreWrapper.CoreStreamMessageWrapper

public final class CoreStreamMessageWrapper
extends CoreMessageWrapper

Field Summary

Fields

Modifier and Type	Field	Description
static final byte	TYPE

Fields inherited from class CoreMessageWrapper

message

Constructor Summary

Constructors

Constructor	Description
CoreStreamMessageWrapper(ICoreMessage message)

Method Summary

Modifier and Type	Method	Description
void	clearBody()
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)
void	decode()
void	encode()	Encode the body into the internal message
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)

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

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

TYPE

public static final byte TYPE

See Also:

• Constant Field Values

Constructor Details

CoreStreamMessageWrapper

public CoreStreamMessageWrapper(ICoreMessage message)

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:

createAMQPSection in class CoreMessageWrapper

Throws:

ConversionException

readBoolean

public boolean readBoolean()
                    throws MessageEOFException,
ConversionException

Throws:

MessageEOFException

ConversionException

readByte

public byte readByte()
              throws MessageEOFException,
ConversionException

Throws:

MessageEOFException

ConversionException

readShort

public short readShort()
                throws MessageEOFException,
ConversionException

Throws:

MessageEOFException

ConversionException

readChar

public char readChar()
              throws MessageEOFException,
ConversionException

Throws:

MessageEOFException

ConversionException

readInt

public int readInt()
            throws MessageEOFException,
ConversionException

Throws:

MessageEOFException

ConversionException

readLong

public long readLong()
              throws ConversionException,
MessageEOFException

Throws:

ConversionException

MessageEOFException

readFloat

public float readFloat()
                throws ConversionException,
MessageEOFException

Throws:

ConversionException

MessageEOFException

readDouble

public double readDouble()
                  throws ConversionException,
MessageEOFException

Throws:

ConversionException

MessageEOFException

readString

public String readString()
                  throws ConversionException,
MessageEOFException

Throws:

ConversionException

MessageEOFException

readBytes

public int readBytes(byte[] value)
              throws ConversionException,
MessageEOFException

Throws:

ConversionException

MessageEOFException

readObject

public Object readObject()
                  throws ConversionException,
MessageEOFException

Throws:

ConversionException

MessageEOFException

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

public void writeString(String value)

writeBytes

public void writeBytes(byte[] value)

writeBytes

public void writeBytes(byte[] value,
 int offset,
 int length)

writeObject

public void writeObject(Object value)
                 throws ConversionException

Throws:

ConversionException

reset

public void reset()

clearBody

public void clearBody()

Overrides:

clearBody in class CoreMessageWrapper

decode

public void decode()

Overrides:

decode in class CoreMessageWrapper

encode

public void encode()

Description copied from class: CoreMessageWrapper

Encode the body into the internal message

Overrides:

encode in class CoreMessageWrapper