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

Interface MessageInternal

All Superinterfaces:

Message

All Known Subinterfaces:

LargeServerMessage, ServerMessage

All Known Implementing Classes:

ClientLargeMessageImpl, ClientMessageImpl, LargeServerMessageImpl, MessageImpl, ServerMessageImpl

public interface MessageInternal
extends Message

Field Summary

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

BYTES_TYPE, DEFAULT_TYPE, HDR_ACTUAL_EXPIRY_TIME, HDR_CONTENT_TYPE, HDR_DUPLICATE_DETECTION_ID, HDR_GROUP_ID, HDR_LARGE_BODY_SIZE, HDR_LARGE_COMPRESSED, HDR_LAST_VALUE_NAME, HDR_ORIG_MESSAGE_ID, HDR_ORIGINAL_ADDRESS, HDR_ORIGINAL_QUEUE, HDR_ROUTE_TO_IDS, HDR_ROUTING_TYPE, HDR_SCHEDULED_DELIVERY_TIME, HDR_VALIDATED_USER, MAP_TYPE, OBJECT_TYPE, STREAM_TYPE, TEXT_TYPE

Method Summary

Modifier and Type	Method and Description
void	bodyChanged()
void	decodeFromBuffer(ActiveMQBuffer buffer)
void	decodeHeadersAndProperties(ActiveMQBuffer buffer)
void	encodeHeadersAndProperties(ActiveMQBuffer buffer)
BodyEncoder	getBodyEncoder()
InputStream	getBodyInputStream()
ActiveMQBuffer	getEncodedBuffer()
int	getEndOfBodyPosition()
int	getEndOfMessagePosition()
int	getHeadersAndPropertiesEncodeSize()
TypedProperties	getTypedProperties()
ActiveMQBuffer	getWholeBuffer()
boolean	isServerMessage()
void	setAddressTransient(SimpleString address)

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

containsProperty, containsProperty, getAddress, getBodyBuffer, getBodyBufferDuplicate, getBooleanProperty, getBooleanProperty, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getDoubleProperty, getDoubleProperty, getEncodeSize, getExpiration, getFloatProperty, getFloatProperty, getIntProperty, getIntProperty, getLongProperty, getLongProperty, getMessageID, getObjectProperty, getObjectProperty, getPriority, getPropertyNames, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getType, getUserID, isDurable, isExpired, isLargeMessage, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putCharProperty, putCharProperty, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putObjectProperty, putObjectProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, removeProperty, removeProperty, setAddress, setDurable, setExpiration, setPriority, setTimestamp, setUserID, toMap, toPropertyMap, writeBodyBufferBytes, writeBodyBufferString

Method Detail

decodeFromBuffer

void decodeFromBuffer(ActiveMQBuffer buffer)

getEndOfMessagePosition

int getEndOfMessagePosition()

getEndOfBodyPosition

int getEndOfBodyPosition()

bodyChanged

void bodyChanged()

isServerMessage

boolean isServerMessage()

getEncodedBuffer

ActiveMQBuffer getEncodedBuffer()

getHeadersAndPropertiesEncodeSize

int getHeadersAndPropertiesEncodeSize()

getWholeBuffer

ActiveMQBuffer getWholeBuffer()

encodeHeadersAndProperties

void encodeHeadersAndProperties(ActiveMQBuffer buffer)

decodeHeadersAndProperties

void decodeHeadersAndProperties(ActiveMQBuffer buffer)

getBodyEncoder

BodyEncoder getBodyEncoder()
                    throws ActiveMQException

Throws:

ActiveMQException

getBodyInputStream

InputStream getBodyInputStream()

setAddressTransient

void setAddressTransient(SimpleString address)

getTypedProperties

TypedProperties getTypedProperties()