public class ServerMessageImpl extends MessageImpl implements ServerMessage
address, BODY_OFFSET, bodyBuffer, buffer, BUFFER_HEADER_SPACE, bufferValid, durable, HDR_BRIDGE_DUPLICATE_ID, HDR_ROUTE_TO_IDS, messageID, priority, properties, timestamp, type
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 | Constructor and Description |
---|---|
|
ServerMessageImpl() |
|
ServerMessageImpl(long messageID,
int initialMessageBufferSize) |
protected |
ServerMessageImpl(ServerMessageImpl other) |
protected |
ServerMessageImpl(ServerMessageImpl other,
TypedProperties properties) |
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
|
InputStream |
getBodyInputStream() |
byte[] |
getDuplicateIDBytes() |
Object |
getDuplicateProperty() |
int |
getMemoryEstimate() |
PagingStore |
getPagingStore() |
int |
getRefCount() |
boolean |
hasInternalProperties() |
int |
incrementDurableRefCount() |
int |
incrementRefCount() |
boolean |
isLargeMessage()
Returns whether this message is a large message or a regular message.
|
boolean |
isServerMessage() |
ServerMessage |
makeCopyForExpiryOrDLA(long newID,
MessageReference originalReference,
boolean expiry) |
void |
setMessageID(long id) |
void |
setOriginalHeaders(ServerMessage other,
MessageReference originalReference,
boolean expiry) |
void |
setPagingStore(PagingStore pagingStore) |
boolean |
storeIsPaging() |
String |
toString() |
bodyChanged, checkCompletion, checkCopy, containsProperty, containsProperty, copyHeadersAndProperties, createBody, decode, decodeFromBuffer, decodeHeadersAndProperties, encode, encodeHeadersAndProperties, getAddress, getBodyBuffer, getBodyBufferCopy, getBodyEncoder, getBooleanProperty, getBooleanProperty, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getDoubleProperty, getDoubleProperty, getEncodedBuffer, getEncodeSize, getEndOfBodyPosition, getEndOfMessagePosition, getExpiration, getFloatProperty, getFloatProperty, getHeadersAndPropertiesEncodeSize, getIntProperty, getIntProperty, getLongProperty, getLongProperty, getMessageID, getObjectProperty, getObjectProperty, getPriority, getProperties, getPropertyNames, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getType, getTypedProperties, getUserID, getWholeBuffer, isDurable, isExpired, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putObjectProperty, putObjectProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, putTypedProperties, removeProperty, removeProperty, resetCopied, setAddress, setAddressTransient, setDurable, setExpiration, setPriority, setTimestamp, setType, setUserID, toMap
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
bodyChanged, checkCopy, decodeFromBuffer, decodeHeadersAndProperties, encodeHeadersAndProperties, getBodyEncoder, getEncodedBuffer, getEndOfBodyPosition, getEndOfMessagePosition, getHeadersAndPropertiesEncodeSize, getTypedProperties, getWholeBuffer, 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, 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
public ServerMessageImpl()
public ServerMessageImpl(long messageID, int initialMessageBufferSize)
protected ServerMessageImpl(ServerMessageImpl other)
protected ServerMessageImpl(ServerMessageImpl other, TypedProperties properties)
public boolean isServerMessage()
isServerMessage
in interface MessageInternal
public void setMessageID(long id)
setMessageID
in interface ServerMessage
public MessageReference createReference(Queue queue)
createReference
in interface ServerMessage
public boolean hasInternalProperties()
hasInternalProperties
in interface ServerMessage
public int incrementRefCount() throws Exception
incrementRefCount
in interface ServerMessage
Exception
public int decrementRefCount() throws Exception
decrementRefCount
in interface ServerMessage
Exception
public int incrementDurableRefCount()
incrementDurableRefCount
in interface ServerMessage
public int decrementDurableRefCount()
decrementDurableRefCount
in interface ServerMessage
public int getRefCount()
getRefCount
in interface ServerMessage
public boolean isLargeMessage()
Message
isLargeMessage
in interface Message
public int getMemoryEstimate()
getMemoryEstimate
in interface ServerMessage
public ServerMessage copy(long newID)
copy
in interface ServerMessage
public void finishCopy() throws Exception
finishCopy
in interface ServerMessage
Exception
public ServerMessage copy()
copy
in interface ServerMessage
public ServerMessage makeCopyForExpiryOrDLA(long newID, MessageReference originalReference, boolean expiry) throws Exception
makeCopyForExpiryOrDLA
in interface ServerMessage
Exception
public void setOriginalHeaders(ServerMessage other, MessageReference originalReference, boolean expiry)
setOriginalHeaders
in interface ServerMessage
public void setPagingStore(PagingStore pagingStore)
setPagingStore
in interface ServerMessage
public void forceAddress(SimpleString address)
ServerMessage
forceAddress
in interface ServerMessage
public PagingStore getPagingStore()
getPagingStore
in interface ServerMessage
public boolean storeIsPaging()
storeIsPaging
in interface ServerMessage
public InputStream getBodyInputStream()
getBodyInputStream
in interface MessageInternal
public void encodeMessageIDToBuffer()
encodeMessageIDToBuffer
in interface ServerMessage
public byte[] getDuplicateIDBytes()
getDuplicateIDBytes
in interface ServerMessage
public Object getDuplicateProperty()
getDuplicateProperty
in interface ServerMessage
Copyright © 2018 JBoss by Red Hat. All rights reserved.