org.apache.activemq.artemis.core.server

Interface LargeServerMessage

All Superinterfaces:

EncodingSupport, Message, MessageInternal, ReplicatedLargeMessage, ServerMessage

All Known Implementing Classes:

LargeServerMessageImpl

public interface LargeServerMessage
extends ServerMessage, ReplicatedLargeMessage

Field Summary

Fields inherited from interface org.apache.activemq.artemis.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_ORIGINAL_QUEUE, HDR_SCHEDULED_DELIVERY_TIME, MAP_TYPE, OBJECT_TYPE, STREAM_TYPE, TEXT_TYPE

Method Summary

Modifier and Type	Method and Description
void	addBytes(byte[] bytes)
void	decrementDelayDeletionCount()
void	deleteFile()
SequentialFile	getFile()
long	getPendingRecordID()
void	incrementDelayDeletionCount()
void	releaseResources() Close the files if opened
void	setPaged() We have to copy the large message content in case of DLQ and paged messages For that we need to pre-mark the LargeMessage with a flag when it is paged
void	setPendingRecordID(long pendingRecordID)

Methods inherited from interface org.apache.activemq.artemis.core.server.ServerMessage

copy, copy, createReference, decrementDurableRefCount, decrementRefCount, encodeMessageIDToBuffer, finishCopy, forceAddress, getDuplicateIDBytes, getDuplicateProperty, getMemoryEstimate, getPagingStore, getRefCount, hasInternalProperties, incrementDurableRefCount, incrementRefCount, makeCopyForExpiryOrDLA, setMessageID, setOriginalHeaders, setPagingStore, 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, writeBodyBufferBytes, writeBodyBufferString

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

decode, encode, getEncodeSize

Methods inherited from interface org.apache.activemq.artemis.core.replication.ReplicatedLargeMessage

setDurable, setMessageID

Method Detail

addBytes

void addBytes(byte[] bytes)
       throws Exception

Specified by:

addBytes in interface ReplicatedLargeMessage

Throws:

Exception

See Also:

addBytes(byte[])

setPendingRecordID

void setPendingRecordID(long pendingRecordID)

getPendingRecordID

long getPendingRecordID()

setPaged

void setPaged()

We have to copy the large message content in case of DLQ and paged messages For that we need to pre-mark the LargeMessage with a flag when it is paged

releaseResources

void releaseResources()

Close the files if opened

Specified by:

releaseResources in interface ReplicatedLargeMessage

See Also:

releaseResources()

deleteFile

void deleteFile()
         throws Exception

Specified by:

deleteFile in interface ReplicatedLargeMessage

Throws:

Exception

See Also:

deleteFile()

incrementDelayDeletionCount

void incrementDelayDeletionCount()

decrementDelayDeletionCount

void decrementDelayDeletionCount()
                          throws Exception

Throws:

Exception

getFile

SequentialFile getFile()
                throws ActiveMQException

Returns:

Throws:

ActiveMQException