org.hornetq.core.server

Interface ServerMessage

All Superinterfaces:

EncodingSupport, Message, MessageInternal

All Known Subinterfaces:

LargeServerMessage

All Known Implementing Classes:

LargeServerMessageImpl, NullStorageLargeServerMessage, ServerMessageImpl

public interface ServerMessage
extends MessageInternal, EncodingSupport

A ServerMessage

Author:

Tim Fox, Clebert Suconic

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
ServerMessage	copy()
ServerMessage	copy(long newID)
MessageReference	createReference(Queue queue)
int	decrementDurableRefCount()
int	decrementRefCount()
void	encodeMessageIDToBuffer()
void	finishCopy()
byte[]	getDuplicateIDBytes()
Object	getDuplicateProperty()
int	getMemoryEstimate()
PagingStore	getPagingStore()
int	getRefCount()
boolean	hasInternalProperties()
int	incrementDurableRefCount()
int	incrementRefCount()
ServerMessage	makeCopyForExpiryOrDLA(long newID, boolean expiry)
void	setMessageID(long id)
void	setOriginalHeaders(ServerMessage other, boolean expiry)
void	setPagingStore(PagingStore store)
boolean	storeIsPaging()

Methods inherited from interface org.hornetq.core.message.impl.MessageInternal

bodyChanged, checkCopy, decodeFromBuffer, decodeHeadersAndProperties, encodeHeadersAndProperties, getBodyEncoder, getBodyInputStream, getEncodedBuffer, getEndOfBodyPosition, getEndOfMessagePosition, getHeadersAndPropertiesEncodeSize, getTypedProperties, getWholeBuffer, isServerMessage, resetCopied, setAddressTransient

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

Methods inherited from interface org.hornetq.core.journal.EncodingSupport

decode, encode, getEncodeSize

Method Detail

setMessageID

void setMessageID(long id)

createReference

MessageReference createReference(Queue queue)

incrementRefCount

int incrementRefCount()
                      throws Exception

Throws:

Exception

decrementRefCount

int decrementRefCount()
                      throws Exception

Throws:

Exception

incrementDurableRefCount

int incrementDurableRefCount()

decrementDurableRefCount

int decrementDurableRefCount()

copy

ServerMessage copy(long newID)

finishCopy

void finishCopy()
                throws Exception

Throws:

Exception

copy

ServerMessage copy()

getMemoryEstimate

int getMemoryEstimate()

getRefCount

int getRefCount()

makeCopyForExpiryOrDLA

ServerMessage makeCopyForExpiryOrDLA(long newID,
                                   boolean expiry)
                                     throws Exception

Throws:

Exception

setOriginalHeaders

void setOriginalHeaders(ServerMessage other,
                      boolean expiry)

setPagingStore

void setPagingStore(PagingStore store)

getPagingStore

PagingStore getPagingStore()

hasInternalProperties

boolean hasInternalProperties()

storeIsPaging

boolean storeIsPaging()

encodeMessageIDToBuffer

void encodeMessageIDToBuffer()

getDuplicateIDBytes

byte[] getDuplicateIDBytes()

getDuplicateProperty

Object getDuplicateProperty()