org.apache.activemq.artemis.core.client.impl

Class ClientMessageImpl

java.lang.Object

org.apache.activemq.artemis.api.core.RefCountMessage

org.apache.activemq.artemis.core.message.impl.CoreMessage

org.apache.activemq.artemis.core.client.impl.ClientMessageImpl

All Implemented Interfaces:

ClientMessage, ICoreMessage, Message, ClientMessageInternal

Direct Known Subclasses:

ClientLargeMessageImpl

public class ClientMessageImpl
extends CoreMessage
implements ClientMessageInternal

A ClientMessageImpl

Field Summary

Fields

Modifier and Type	Field and Description
static SimpleString	REPLYTO_HEADER_NAME

Fields inherited from class org.apache.activemq.artemis.core.message.impl.CoreMessage

address, BODY_OFFSET, buffer, BUFFER_HEADER_SPACE, durable, endOfBodyPosition, messageID, messageIDPosition, priority, properties, timestamp, type, writableBuffer

Fields inherited from interface org.apache.activemq.artemis.api.core.Message

BYTES_TYPE, DEFAULT_TYPE, EMBEDDED_TYPE, HDR_ACTUAL_EXPIRY_TIME, HDR_BRIDGE_DUPLICATE_ID, HDR_CONTENT_TYPE, HDR_DUPLICATE_DETECTION_ID, HDR_GROUP_ID, HDR_GROUP_SEQUENCE, HDR_LARGE_BODY_SIZE, HDR_LARGE_COMPRESSED, HDR_LAST_VALUE_NAME, HDR_ORIG_MESSAGE_ID, HDR_ORIGINAL_ADDRESS, HDR_ORIGINAL_QUEUE, HDR_PREFIX, HDR_ROUTE_TO_ACK_IDS, HDR_ROUTE_TO_IDS, HDR_ROUTING_TYPE, HDR_SCALEDOWN_TO_IDS, HDR_SCHEDULED_DELIVERY_TIME, HDR_VALIDATED_USER, MAP_TYPE, memoryOffset, OBJECT_TYPE, STREAM_TYPE, TEXT_TYPE

Constructor Summary

Constructors

Modifier	Constructor and Description
	ClientMessageImpl()
	ClientMessageImpl(byte type, boolean durable, long expiration, long timestamp, byte priority, int initialMessageBufferSize)
	ClientMessageImpl(byte type, boolean durable, long expiration, long timestamp, byte priority, int initialMessageBufferSize, CoreMessageObjectPools coreMessageObjectPools)
protected	ClientMessageImpl(ClientMessageImpl other)
	ClientMessageImpl(CoreMessageObjectPools coreMessageObjectPools)

Method Summary

Modifier and Type	Method and Description
ClientMessageImpl	acknowledge() Acknowledges reception of this message.
void	checkCompletion() This can be optionally used to verify if the entire message has been received.
Message	copy() It will generate a new instance of the message encode, being a deep copy, new properties, new everything
void	discardBody() Discard unused packets (used on large-message)
LargeBodyEncoder	getBodyEncoder()
InputStream	getBodyInputStream() Return the bodyInputStream for large messages
int	getBodySize() Returns the size (in bytes) of this message's body
int	getDeliveryCount() Returns the number of times this message was delivered.
int	getFlowControlSize() Size used for FlowControl
ClientMessageImpl	individualAcknowledge() Acknowledges reception of a single message.
boolean	isCompressed()
boolean	isLargeMessage()
void	onReceipt(ClientConsumerInternal consumer)
ClientMessageImpl	putBooleanProperty(SimpleString key, boolean value) Overridden from Message to enable fluent API
ClientMessageImpl	putBooleanProperty(String key, boolean value) Overridden from Message to enable fluent API
ClientMessageImpl	putByteProperty(SimpleString key, byte value) Overridden from Message to enable fluent API
ClientMessageImpl	putByteProperty(String key, byte value) Overridden from Message to enable fluent API
ClientMessageImpl	putBytesProperty(SimpleString key, byte[] value) Overridden from Message to enable fluent API
ClientMessageImpl	putBytesProperty(String key, byte[] value) Overridden from Message to enable fluent API
ClientMessageImpl	putCharProperty(SimpleString key, char value) Overridden from Message to enable fluent API
ClientMessageImpl	putCharProperty(String key, char value) Overridden from Message to enable fluent API
ClientMessageImpl	putDoubleProperty(SimpleString key, double value) Overridden from Message to enable fluent API
ClientMessageImpl	putDoubleProperty(String key, double value) Overridden from Message to enable fluent API
ClientMessageImpl	putFloatProperty(SimpleString key, float value) Overridden from Message to enable fluent API
ClientMessageImpl	putFloatProperty(String key, float value) Overridden from Message to enable fluent API
ClientMessageImpl	putIntProperty(SimpleString key, int value) Overridden from Message to enable fluent API
ClientMessageImpl	putIntProperty(String key, int value) Overridden from Message to enable fluent API
ClientMessageImpl	putLongProperty(SimpleString key, long value) Overridden from Message to enable fluent API
ClientMessageImpl	putLongProperty(String key, long value) Overridden from Message to enable fluent API
ClientMessageImpl	putObjectProperty(SimpleString key, Object value)
ClientMessageImpl	putObjectProperty(String key, Object value)
ClientMessageImpl	putShortProperty(SimpleString key, short value) Overridden from Message to enable fluent API
ClientMessageImpl	putShortProperty(String key, short value) Overridden from Message to enable fluent API
ClientMessageImpl	putStringProperty(SimpleString key, SimpleString value)
ClientMessageImpl	putStringProperty(SimpleString key, String value)
ClientMessageImpl	putStringProperty(String key, String value) Puts a String property in this message.
void	saveToOutputStream(OutputStream out) Saves the content of the message to the OutputStream.
ClientMessageImpl	setBodyInputStream(InputStream bodyInputStream) Sets the body's IntputStream.
ClientMessageImpl	setDeliveryCount(int deliveryCount) Sets the delivery count for this message.
ClientMessageImpl	setDurable(boolean durable) Sets whether this message is durable or not.
ClientMessageImpl	setExpiration(long expiration) Sets the expiration of this message.
void	setFlowControlSize(int flowControlSize) Size used for FlowControl
ClientMessageImpl	setOutputStream(OutputStream out) Sets the OutputStream that will receive the content of a message received in a non blocking way.
ClientMessageImpl	setPriority(byte priority) Sets the message priority.
ClientMessageImpl	setUserID(UUID userID)
String	toString()
boolean	waitOutputStreamCompletion(long timeMilliseconds) Wait the outputStream completion of the message.
ClientMessageImpl	writeBodyBufferBytes(byte[] bytes) Overridden from Message to enable fluent API
ClientMessageImpl	writeBodyBufferString(String string) Overridden from Message to enable fluent API

Methods inherited from class org.apache.activemq.artemis.core.message.impl.CoreMessage

checkEncode, clearInternalProperties, containsProperty, containsProperty, copy, copyHeadersAndProperties, decodeHeadersAndProperties, encode, encodeHeadersAndProperties, getAddress, getAddressSimpleString, getAnnotation, getBodyBuffer, getBodyBufferSize, getBooleanProperty, getBooleanProperty, getBuffer, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getCorrelationID, getDataBuffer, getDoubleProperty, getDoubleProperty, getDuplicateProperty, getEncodeSize, getEndOfBodyPosition, getExpiration, getFloatProperty, getFloatProperty, getGroupID, getGroupSequence, getHeadersAndPropertiesEncodeSize, getIntProperty, getIntProperty, getLastValueProperty, getLongProperty, getLongProperty, getMemoryEstimate, getMessageID, getObjectProperty, getObjectProperty, getPersistentSize, getPersister, getPersistSize, getPriority, getProperties, getPropertyNames, getReadOnlyBodyBuffer, getReplyTo, getRoutingType, getScheduledDeliveryTime, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getType, getUserID, getValidatedUserID, initBuffer, isDurable, isServerMessage, messageChanged, persist, receiveBuffer_1X, receiveBuffer, reloadPersistence, removeAnnotation, removeProperty, removeProperty, sendBuffer_1X, sendBuffer, setAddress, setAddress, setBuffer, setCorrelationID, setGroupID, setGroupID, setGroupSequence, setLastValueProperty, setMessageID, setReplyTo, setRoutingType, setScheduledDeliveryTime, setTimestamp, setType, setUserID, setValidatedUserID, toCore, toCore

Methods inherited from class org.apache.activemq.artemis.api.core.RefCountMessage

decrementDurableRefCount, decrementRefCount, getContext, getRefCount, incrementDurableRefCount, incrementRefCount, setContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.core.client.impl.ClientMessageInternal

getProperties

Methods inherited from interface org.apache.activemq.artemis.api.core.client.ClientMessage

getBodyBuffer

Methods inherited from interface org.apache.activemq.artemis.api.core.ICoreMessage

copyHeadersAndProperties, getBodyBufferSize, getDataBuffer, getEndOfBodyPosition, getHeadersAndPropertiesEncodeSize, getReadOnlyBodyBuffer, getType, isServerMessage, receiveBuffer_1X, sendBuffer_1X, setType, toMap

Methods inherited from interface org.apache.activemq.artemis.api.core.Message

acceptsConsumer, clearInternalProperties, containsProperty, containsProperty, copy, decrementDurableRefCount, decrementRefCount, getAddress, getAddressSimpleString, getAnnotation, getAnnotationString, getBooleanProperty, getBooleanProperty, getBuffer, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getConnectionID, getContext, getCorrelationID, getDoubleProperty, getDoubleProperty, getDuplicateIDBytes, getDuplicateProperty, getEncodeSize, getExpiration, getExtraBytesProperty, getFloatProperty, getFloatProperty, getGroupID, getGroupSequence, getIntProperty, getIntProperty, getLastValueProperty, getLongProperty, getLongProperty, getMemoryEstimate, getMessageID, getObjectProperty, getObjectProperty, getPersistentSize, getPersister, getPersistSize, getPriority, getPropertyNames, getRefCount, getReplyTo, getRoutingType, getScheduledDeliveryTime, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getUserID, getValidatedUserID, incrementDurableRefCount, incrementRefCount, isDurable, isExpired, messageChanged, persist, putExtraBytesProperty, receiveBuffer, reencode, referenceOriginalMessage, rejectConsumer, releaseBuffer, reloadPersistence, removeAnnotation, removeExtraBytesProperty, removeProperty, removeProperty, sendBuffer, setAddress, setAddress, setAnnotation, setBuffer, setConnectionID, setContext, setCorrelationID, setGroupID, setGroupID, setGroupSequence, setLastValueProperty, setMessageID, setReplyTo, setRoutingType, setScheduledDeliveryTime, setTimestamp, setUserID, setValidatedUserID, toCore, toCore, toPropertyMap

Field Detail

REPLYTO_HEADER_NAME

public static final SimpleString REPLYTO_HEADER_NAME

Constructor Detail

ClientMessageImpl

public ClientMessageImpl()

ClientMessageImpl

public ClientMessageImpl(CoreMessageObjectPools coreMessageObjectPools)

ClientMessageImpl

protected ClientMessageImpl(ClientMessageImpl other)

ClientMessageImpl

public ClientMessageImpl(byte type,
                         boolean durable,
                         long expiration,
                         long timestamp,
                         byte priority,
                         int initialMessageBufferSize,
                         CoreMessageObjectPools coreMessageObjectPools)

ClientMessageImpl

public ClientMessageImpl(byte type,
                         boolean durable,
                         long expiration,
                         long timestamp,
                         byte priority,
                         int initialMessageBufferSize)

Method Detail

setDurable

public ClientMessageImpl setDurable(boolean durable)

Description copied from interface: Message

Sets whether this message is durable or not.

Specified by:

setDurable in interface Message

Overrides:

setDurable in class CoreMessage

Parameters:

durable - true to flag this message as durable, false else

setExpiration

public ClientMessageImpl setExpiration(long expiration)

Description copied from interface: Message

Sets the expiration of this message.

Specified by:

setExpiration in interface Message

Overrides:

setExpiration in class CoreMessage

Parameters:

expiration - expiration time

setPriority

public ClientMessageImpl setPriority(byte priority)

Description copied from interface: Message

Sets the message priority.

Value must be between 0 and 9 inclusive.

Specified by:

setPriority in interface Message

Overrides:

setPriority in class CoreMessage

Parameters:

priority - the new message priority

setUserID

public ClientMessageImpl setUserID(UUID userID)

Overrides:

setUserID in class CoreMessage

onReceipt

public void onReceipt(ClientConsumerInternal consumer)

Specified by:

onReceipt in interface ClientMessageInternal

setDeliveryCount

public ClientMessageImpl setDeliveryCount(int deliveryCount)

Description copied from interface: ClientMessage

Sets the delivery count for this message.

This method is not meant to be called by ActiveMQ Artemis clients.

Specified by:

setDeliveryCount in interface ClientMessage

Parameters:

deliveryCount - message delivery count

Returns:

this ClientMessage

getDeliveryCount

public int getDeliveryCount()

Description copied from interface: ClientMessage

Returns the number of times this message was delivered.

Specified by:

getDeliveryCount in interface ClientMessage

acknowledge

public ClientMessageImpl acknowledge()
                              throws ActiveMQException

Description copied from interface: ClientMessage

Acknowledges reception of this message.

If the session responsible to acknowledge this message has autoCommitAcks set to true, the transaction will automatically commit the current transaction. Otherwise, this acknowledgement will not be committed until the client commits the session transaction.

Specified by:

acknowledge in interface ClientMessage

Throws:

ActiveMQException - if an error occurred while acknowledging the message.

See Also:

ClientSession.isAutoCommitAcks()

individualAcknowledge

public ClientMessageImpl individualAcknowledge()
                                        throws ActiveMQException

Description copied from interface: ClientMessage

Acknowledges reception of a single message.

If the session responsible to acknowledge this message has autoCommitAcks set to true, the transaction will automatically commit the current transaction. Otherwise, this acknowledgement will not be committed until the client commits the session transaction.

Specified by:

individualAcknowledge in interface ClientMessage

Throws:

ActiveMQException - if an error occurred while acknowledging the message.

See Also:

ClientSession.isAutoCommitAcks()

checkCompletion

public void checkCompletion()
                     throws ActiveMQException

Description copied from interface: ClientMessage

This can be optionally used to verify if the entire message has been received. It won't have any effect on regular messages but it may be helpful on large messages. The use case for this is to make sure there won't be an exception while getting the buffer. Using getBodyBuffer directly would have the same effect but you could get a Runtime non checked Exception instead

Specified by:

checkCompletion in interface ClientMessage

Throws:

ActiveMQException

getFlowControlSize

public int getFlowControlSize()

Description copied from interface: ClientMessageInternal

Size used for FlowControl

Specified by:

getFlowControlSize in interface ClientMessageInternal

setFlowControlSize

public void setFlowControlSize(int flowControlSize)

Description copied from interface: ClientMessageInternal

Size used for FlowControl

Specified by:

setFlowControlSize in interface ClientMessageInternal

isLargeMessage

public boolean isLargeMessage()

Specified by:

isLargeMessage in interface Message

Overrides:

isLargeMessage in class CoreMessage

Returns:

the largeMessage

isCompressed

public boolean isCompressed()

Specified by:

isCompressed in interface ClientMessageInternal

getBodySize

public int getBodySize()

Description copied from interface: ClientMessage

Returns the size (in bytes) of this message's body

Specified by:

getBodySize in interface ClientMessage

toString

public String toString()

Overrides:

toString in class CoreMessage

saveToOutputStream

public void saveToOutputStream(OutputStream out)
                        throws ActiveMQException

Description copied from interface: ClientMessage

Saves the content of the message to the OutputStream. It will block until the entire content is transferred to the OutputStream.

Specified by:

saveToOutputStream in interface ClientMessage

Throws:

ActiveMQException

setOutputStream

public ClientMessageImpl setOutputStream(OutputStream out)
                                  throws ActiveMQException

Description copied from interface: ClientMessage

Sets the OutputStream that will receive the content of a message received in a non blocking way.
This method is used when consuming large messages

Specified by:

setOutputStream in interface ClientMessage

Returns:

this ClientMessage

Throws:

ActiveMQException

waitOutputStreamCompletion

public boolean waitOutputStreamCompletion(long timeMilliseconds)
                                   throws ActiveMQException

Description copied from interface: ClientMessage

Wait the outputStream completion of the message. This method is used when consuming large messages

Specified by:

waitOutputStreamCompletion in interface ClientMessage

Parameters:

timeMilliseconds - - 0 means wait forever

Returns:

true if it reached the end

Throws:

ActiveMQException

discardBody

public void discardBody()

Description copied from interface: ClientMessageInternal

Discard unused packets (used on large-message)

Specified by:

discardBody in interface ClientMessageInternal

getBodyInputStream

public InputStream getBodyInputStream()

Description copied from interface: ClientMessage

Return the bodyInputStream for large messages

Specified by:

getBodyInputStream in interface ClientMessage

Specified by:

getBodyInputStream in interface ICoreMessage

Specified by:

getBodyInputStream in interface Message

Overrides:

getBodyInputStream in class CoreMessage

Returns:

the bodyInputStream

setBodyInputStream

public ClientMessageImpl setBodyInputStream(InputStream bodyInputStream)

Description copied from interface: ClientMessage

Sets the body's IntputStream.
This method is used when sending large messages

Specified by:

setBodyInputStream in interface ClientMessage

Parameters:

bodyInputStream - the bodyInputStream to set

Returns:

this ClientMessage

getBodyEncoder

public LargeBodyEncoder getBodyEncoder()
                                throws ActiveMQException

Specified by:

getBodyEncoder in interface ICoreMessage

Overrides:

getBodyEncoder in class CoreMessage

Throws:

ActiveMQException

putBooleanProperty

public ClientMessageImpl putBooleanProperty(SimpleString key,
                                            boolean value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putBooleanProperty in interface ClientMessage

Specified by:

putBooleanProperty in interface Message

Overrides:

putBooleanProperty in class CoreMessage

putByteProperty

public ClientMessageImpl putByteProperty(SimpleString key,
                                         byte value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putByteProperty in interface ClientMessage

Specified by:

putByteProperty in interface Message

Overrides:

putByteProperty in class CoreMessage

putBytesProperty

public ClientMessageImpl putBytesProperty(SimpleString key,
                                          byte[] value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putBytesProperty in interface ClientMessage

Specified by:

putBytesProperty in interface Message

Overrides:

putBytesProperty in class CoreMessage

putCharProperty

public ClientMessageImpl putCharProperty(SimpleString key,
                                         char value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putCharProperty in interface ClientMessage

Specified by:

putCharProperty in interface Message

Overrides:

putCharProperty in class CoreMessage

putCharProperty

public ClientMessageImpl putCharProperty(String key,
                                         char value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putCharProperty in interface ClientMessage

Specified by:

putCharProperty in interface Message

Overrides:

putCharProperty in class CoreMessage

putShortProperty

public ClientMessageImpl putShortProperty(SimpleString key,
                                          short value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putShortProperty in interface ClientMessage

Specified by:

putShortProperty in interface Message

Overrides:

putShortProperty in class CoreMessage

putIntProperty

public ClientMessageImpl putIntProperty(SimpleString key,
                                        int value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putIntProperty in interface ClientMessage

Specified by:

putIntProperty in interface Message

Overrides:

putIntProperty in class CoreMessage

putLongProperty

public ClientMessageImpl putLongProperty(SimpleString key,
                                         long value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putLongProperty in interface ClientMessage

Specified by:

putLongProperty in interface Message

Overrides:

putLongProperty in class CoreMessage

putFloatProperty

public ClientMessageImpl putFloatProperty(SimpleString key,
                                          float value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putFloatProperty in interface ClientMessage

Specified by:

putFloatProperty in interface Message

Overrides:

putFloatProperty in class CoreMessage

putDoubleProperty

public ClientMessageImpl putDoubleProperty(SimpleString key,
                                           double value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putDoubleProperty in interface ClientMessage

Specified by:

putDoubleProperty in interface Message

Overrides:

putDoubleProperty in class CoreMessage

putStringProperty

public ClientMessageImpl putStringProperty(SimpleString key,
                                           SimpleString value)

Specified by:

putStringProperty in interface Message

Overrides:

putStringProperty in class CoreMessage

putStringProperty

public ClientMessageImpl putStringProperty(SimpleString key,
                                           String value)

Specified by:

putStringProperty in interface Message

Overrides:

putStringProperty in class CoreMessage

putObjectProperty

public ClientMessageImpl putObjectProperty(SimpleString key,
                                           Object value)
                                    throws ActiveMQPropertyConversionException

Specified by:

putObjectProperty in interface Message

Overrides:

putObjectProperty in class CoreMessage

Throws:

ActiveMQPropertyConversionException

putObjectProperty

public ClientMessageImpl putObjectProperty(String key,
                                           Object value)
                                    throws ActiveMQPropertyConversionException

Specified by:

putObjectProperty in interface Message

Overrides:

putObjectProperty in class CoreMessage

Throws:

ActiveMQPropertyConversionException

putBooleanProperty

public ClientMessageImpl putBooleanProperty(String key,
                                            boolean value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putBooleanProperty in interface ClientMessage

Specified by:

putBooleanProperty in interface Message

Overrides:

putBooleanProperty in class CoreMessage

putByteProperty

public ClientMessageImpl putByteProperty(String key,
                                         byte value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putByteProperty in interface ClientMessage

Specified by:

putByteProperty in interface Message

Overrides:

putByteProperty in class CoreMessage

putBytesProperty

public ClientMessageImpl putBytesProperty(String key,
                                          byte[] value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putBytesProperty in interface ClientMessage

Specified by:

putBytesProperty in interface Message

Overrides:

putBytesProperty in class CoreMessage

putShortProperty

public ClientMessageImpl putShortProperty(String key,
                                          short value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putShortProperty in interface ClientMessage

Specified by:

putShortProperty in interface Message

Overrides:

putShortProperty in class CoreMessage

putIntProperty

public ClientMessageImpl putIntProperty(String key,
                                        int value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putIntProperty in interface ClientMessage

Specified by:

putIntProperty in interface Message

Overrides:

putIntProperty in class CoreMessage

putLongProperty

public ClientMessageImpl putLongProperty(String key,
                                         long value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putLongProperty in interface ClientMessage

Specified by:

putLongProperty in interface Message

Overrides:

putLongProperty in class CoreMessage

putFloatProperty

public ClientMessageImpl putFloatProperty(String key,
                                          float value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putFloatProperty in interface ClientMessage

Specified by:

putFloatProperty in interface Message

Overrides:

putFloatProperty in class CoreMessage

putDoubleProperty

public ClientMessageImpl putDoubleProperty(String key,
                                           double value)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

putDoubleProperty in interface ClientMessage

Specified by:

putDoubleProperty in interface Message

Overrides:

putDoubleProperty in class CoreMessage

putStringProperty

public ClientMessageImpl putStringProperty(String key,
                                           String value)

Description copied from interface: Message

Puts a String property in this message.

Specified by:

putStringProperty in interface ClientMessage

Specified by:

putStringProperty in interface Message

Overrides:

putStringProperty in class CoreMessage

Parameters:

key - property name

value - property value

writeBodyBufferBytes

public ClientMessageImpl writeBodyBufferBytes(byte[] bytes)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

writeBodyBufferBytes in interface ClientMessage

writeBodyBufferString

public ClientMessageImpl writeBodyBufferString(String string)

Description copied from interface: ClientMessage

Overridden from Message to enable fluent API

Specified by:

writeBodyBufferString in interface ClientMessage

copy

public Message copy()

Description copied from interface: Message

It will generate a new instance of the message encode, being a deep copy, new properties, new everything

Specified by:

copy in interface Message

Overrides:

copy in class CoreMessage