public interface ServerMessage extends MessageInternal, EncodingSupport
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 |
---|---|
ServerMessage |
copy() |
ServerMessage |
copy(long newID) |
MessageReference |
createReference(Queue queue) |
int |
decrementDurableRefCount() |
int |
decrementRefCount() |
void |
encodeMessageIDToBuffer() |
void |
finishCopy() |
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) |
void |
setMessageID(long id) |
void |
setOriginalHeaders(ServerMessage other,
MessageReference originalReference,
boolean expiry) |
void |
setPagingStore(PagingStore store) |
boolean |
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, 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
decode, encode, getEncodeSize
void setMessageID(long id)
MessageReference createReference(Queue queue)
void forceAddress(SimpleString address)
address
- int incrementDurableRefCount()
int decrementDurableRefCount()
ServerMessage copy(long newID)
ServerMessage copy()
int getMemoryEstimate()
int getRefCount()
ServerMessage makeCopyForExpiryOrDLA(long newID, MessageReference originalReference, boolean expiry) throws Exception
Exception
void setOriginalHeaders(ServerMessage other, MessageReference originalReference, boolean expiry)
void setPagingStore(PagingStore store)
PagingStore getPagingStore()
boolean hasInternalProperties()
boolean storeIsPaging()
void encodeMessageIDToBuffer()
byte[] getDuplicateIDBytes()
Object getDuplicateProperty()
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.