org.hornetq.core.message.impl

Interface MessageInternal

All Superinterfaces:

Message

All Known Subinterfaces:

ClientLargeMessageInternal, ClientMessageInternal, LargeServerMessage, ServerMessage

All Known Implementing Classes:

ClientLargeMessageImpl, ClientMessageImpl, LargeServerMessageImpl, MessageImpl, NullStorageLargeServerMessage, ServerMessageImpl

public interface MessageInternal
extends Message

A MessageInternal

Author:

Tim Fox TODO - this can be refactored further to separate out large message specific stuff

Field Summary

Fields inherited from interface org.hornetq.api.core.Message

BYTES_TYPE, DEFAULT_TYPE, HDR_ACTUAL_EXPIRY_TIME, 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_SCHEDULED_DELIVERY_TIME, MAP_TYPE, OBJECT_TYPE, STREAM_TYPE, TEXT_TYPE

Method Summary

Methods

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

Methods inherited from interface org.hornetq.api.core.Message

containsProperty, containsProperty, getAddress, getBodyBuffer, 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, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putObjectProperty, putObjectProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, removeProperty, removeProperty, setAddress, setDurable, setExpiration, setPriority, setTimestamp, setUserID, toMap

Method Detail

decodeFromBuffer

void decodeFromBuffer(HornetQBuffer buffer)

getEndOfMessagePosition

int getEndOfMessagePosition()

getEndOfBodyPosition

int getEndOfBodyPosition()

checkCopy

void checkCopy()

bodyChanged

void bodyChanged()

resetCopied

void resetCopied()

isServerMessage

boolean isServerMessage()

getEncodedBuffer

HornetQBuffer getEncodedBuffer()

getHeadersAndPropertiesEncodeSize

int getHeadersAndPropertiesEncodeSize()

getWholeBuffer

HornetQBuffer getWholeBuffer()

encodeHeadersAndProperties

void encodeHeadersAndProperties(HornetQBuffer buffer)

decodeHeadersAndProperties

void decodeHeadersAndProperties(HornetQBuffer buffer)

getBodyEncoder

BodyEncoder getBodyEncoder()
                           throws HornetQException

Throws:

HornetQException

getBodyInputStream

InputStream getBodyInputStream()

setAddressTransient

void setAddressTransient(SimpleString address)

getTypedProperties

TypedProperties getTypedProperties()