org.apache.activemq.artemis.core.server

Interface ServerMessage

All Superinterfaces:

EncodingSupport, Message, MessageInternal

All Known Subinterfaces:

LargeServerMessage

All Known Implementing Classes:

LargeServerMessageImpl, ServerMessageImpl

public interface ServerMessage
extends MessageInternal, EncodingSupport

A ServerMessage

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
ServerMessage	copy()
ServerMessage	copy(long newID)
MessageReference	createReference(Queue queue)
int	decrementDurableRefCount()
int	decrementRefCount()
void	encodeMessageIDToBuffer()
void	forceAddress(SimpleString address) This will force encoding of the address, and will re-check the buffer This is to avoid setMessageTransient which set the address without changing the buffer
byte[]	getDuplicateIDBytes()
Object	getDuplicateProperty()
int	getMemoryEstimate()
PagingStore	getPagingStore()
int	getRefCount()
boolean	hasInternalProperties()
int	incrementDurableRefCount()
int	incrementRefCount()
ServerMessage	makeCopyForExpiryOrDLA(long newID, MessageReference originalReference, boolean expiry, boolean copyOriginalHeaders)
ServerMessage	setMessageID(long id)
void	setOriginalHeaders(ServerMessage other, MessageReference originalReference, boolean expiry)
void	setPagingStore(PagingStore store)
boolean	storeIsPaging()

Methods inherited from interface org.apache.activemq.artemis.core.message.impl.MessageInternal

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

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

Methods inherited from interface org.apache.activemq.artemis.core.journal.EncodingSupport

decode, encode, getEncodeSize

Method Detail

setMessageID

ServerMessage setMessageID(long id)

createReference

MessageReference createReference(Queue queue)

forceAddress

void forceAddress(SimpleString address)

This will force encoding of the address, and will re-check the buffer This is to avoid setMessageTransient which set the address without changing the buffer

Parameters:

address -

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)

copy

ServerMessage copy()

getMemoryEstimate

int getMemoryEstimate()

getRefCount

int getRefCount()

makeCopyForExpiryOrDLA

ServerMessage makeCopyForExpiryOrDLA(long newID,
                                     MessageReference originalReference,
                                     boolean expiry,
                                     boolean copyOriginalHeaders)
                              throws Exception

Throws:

Exception

setOriginalHeaders

void setOriginalHeaders(ServerMessage other,
                        MessageReference originalReference,
                        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()