public interface LargeServerMessage extends ServerMessage, ReplicatedLargeMessage
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
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) |
copy, copy, createReference, decrementDurableRefCount, decrementRefCount, encodeMessageIDToBuffer, finishCopy, forceAddress, getDuplicateIDBytes, getDuplicateProperty, getMemoryEstimate, getPagingStore, getRefCount, hasInternalProperties, incrementDurableRefCount, incrementRefCount, makeCopyForExpiryOrDLA, setMessageID, setOriginalHeaders, setPagingStore, storeIsPaging
bodyChanged, checkCopy, decodeFromBuffer, decodeHeadersAndProperties, encodeHeadersAndProperties, getBodyEncoder, getBodyInputStream, getEncodedBuffer, getEndOfBodyPosition, getEndOfMessagePosition, getHeadersAndPropertiesEncodeSize, getTypedProperties, getWholeBuffer, isServerMessage, resetCopied, setAddressTransient
containsProperty, containsProperty, getAddress, getBodyBuffer, getBodyBufferCopy, 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
decode, encode, getEncodeSize
setDurable, setMessageID
void addBytes(byte[] bytes) throws Exception
addBytes
in interface ReplicatedLargeMessage
Exception
LargeServerMessage#addBytes(byte[])
void setPendingRecordID(long pendingRecordID)
long getPendingRecordID()
void setPaged()
void releaseResources()
releaseResources
in interface ReplicatedLargeMessage
LargeServerMessage#releaseResources()
void deleteFile() throws Exception
deleteFile
in interface ReplicatedLargeMessage
Exception
LargeServerMessage#deleteFile()
void incrementDelayDeletionCount()
SequentialFile getFile() throws HornetQException
HornetQException
Copyright © 2018 JBoss by Red Hat. All rights reserved.