org.hornetq.core.server

Interface LargeServerMessage

All Superinterfaces:

EncodingSupport, Message, MessageInternal, ServerMessage

All Known Implementing Classes:

LargeServerMessageImpl, NullStorageLargeServerMessage

public interface LargeServerMessage
extends ServerMessage

A LargeMessage

Author:

Clebert Suconic Created 30-Sep-08 10:58:04 AM

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	addBytes(byte[] bytes)
void	decrementDelayDeletionCount()
void	deleteFile()
long	getPendingRecordID()
void	incrementDelayDeletionCount()
boolean	isFileExists()
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.hornetq.core.server.ServerMessage

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

addBytes

void addBytes(byte[] bytes)
              throws Exception

Throws:

Exception

setPendingRecordID

void setPendingRecordID(long pendingRecordID)

getPendingRecordID

long getPendingRecordID()

isFileExists

boolean isFileExists()
                     throws Exception

Throws:

Exception

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

deleteFile

void deleteFile()
                throws Exception

Throws:

Exception

incrementDelayDeletionCount

void incrementDelayDeletionCount()

decrementDelayDeletionCount

void decrementDelayDeletionCount()
                                 throws Exception

Throws:

Exception