public class ServerMessageImpl extends MessageImpl implements ServerMessage
address, BODY_OFFSET, bodyBuffer, buffer, BUFFER_HEADER_SPACE, bufferValid, durable, expiration, 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_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() |
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,
boolean expiry) |
void |
setMessageID(long id) |
void |
setOriginalHeaders(ServerMessage other,
boolean expiry) |
void |
setPagingStore(PagingStore pagingStore) |
boolean |
storeIsPaging() |
String |
toString() |
bodyChanged, checkCopy, containsProperty, containsProperty, copyHeadersAndProperties, createBody, decode, decodeFromBuffer, decodeHeadersAndProperties, encode, encodeHeadersAndProperties, getAddress, getBodyBuffer, 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, 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, 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, boolean expiry) throws Exception
makeCopyForExpiryOrDLA
in interface ServerMessage
Exception
public void setOriginalHeaders(ServerMessage other, boolean expiry)
setOriginalHeaders
in interface ServerMessage
public void setPagingStore(PagingStore pagingStore)
setPagingStore
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 © 2012 JBoss by Red Hat. All Rights Reserved.