Class CoreMapMessageWrapper

java.lang.Object

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

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

public final class CoreMapMessageWrapper
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
CoreMapMessageWrapper(ICoreMessage message)	This constructor is used to construct messages prior to sending

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	getBoolean(String name)
byte	getByte(String name)
byte[]	getBytes(String name)
char	getChar(String name)
double	getDouble(String name)
float	getFloat(String name)
int	getInt(String name)
long	getLong(String name)
Enumeration	getMapNames()
Object	getObject(String name)
short	getShort(String name)
String	getString(String name)
boolean	itemExists(String name)
void	setBoolean(String name, boolean value)
void	setByte(String name, byte value)
void	setBytes(String name, byte[] value)
void	setBytes(String name, byte[] value, int offset, int length)
void	setChar(String name, char value)
void	setDouble(String name, double value)
void	setFloat(String name, float value)
void	setInt(String name, int value)
void	setLong(String name, long value)
void	setObject(String name, Object value)
void	setShort(String name, short value)
void	setString(String name, 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

CoreMapMessageWrapper

public CoreMapMessageWrapper(ICoreMessage message)

This constructor is used to construct messages prior to sending

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)

Overrides:

createAMQPSection in class CoreMessageWrapper

setBoolean

public void setBoolean(String name,
 boolean value)

setByte

public void setByte(String name,
 byte value)

setShort

public void setShort(String name,
 short value)

setChar

public void setChar(String name,
 char value)

setInt

public void setInt(String name,
 int value)

setLong

public void setLong(String name,
 long value)

setFloat

public void setFloat(String name,
 float value)

setDouble

public void setDouble(String name,
 double value)

setString

public void setString(String name,
 String value)

setBytes

public void setBytes(String name,
 byte[] value)

setBytes

public void setBytes(String name,
 byte[] value,
 int offset,
 int length)

setObject

public void setObject(String name,
 Object value)
               throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getBoolean

public boolean getBoolean(String name)
                   throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getByte

public byte getByte(String name)
             throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getShort

public short getShort(String name)
               throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getChar

public char getChar(String name)
             throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getInt

public int getInt(String name)
           throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getLong

public long getLong(String name)
             throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getFloat

public float getFloat(String name)
               throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getDouble

public double getDouble(String name)
                 throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getString

public String getString(String name)
                 throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getBytes

public byte[] getBytes(String name)
                throws ActiveMQPropertyConversionException

Throws:

ActiveMQPropertyConversionException

getObject

public Object getObject(String name)

getMapNames

public Enumeration getMapNames()

itemExists

public boolean itemExists(String name)

clearBody

public void clearBody()

Overrides:

clearBody in class CoreMessageWrapper

encode

public void encode()

Description copied from class: CoreMessageWrapper

Encode the body into the internal message

Overrides:

encode in class CoreMessageWrapper

decode

public void decode()

Overrides:

decode in class CoreMessageWrapper