public interface MessageInternal extends 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
Modifier and Type | Method and Description |
---|---|
void |
bodyChanged() |
void |
checkCopy() |
void |
decodeFromBuffer(HornetQBuffer buffer) |
void |
decodeHeadersAndProperties(HornetQBuffer buffer) |
void |
encodeHeadersAndProperties(HornetQBuffer buffer) |
BodyEncoder |
getBodyEncoder() |
InputStream |
getBodyInputStream() |
HornetQBuffer |
getEncodedBuffer() |
int |
getEndOfBodyPosition() |
int |
getEndOfMessagePosition() |
int |
getHeadersAndPropertiesEncodeSize() |
TypedProperties |
getTypedProperties() |
HornetQBuffer |
getWholeBuffer() |
boolean |
isServerMessage() |
void |
resetCopied() |
void |
setAddressTransient(SimpleString address) |
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
void decodeFromBuffer(HornetQBuffer buffer)
int getEndOfMessagePosition()
int getEndOfBodyPosition()
void checkCopy()
void bodyChanged()
void resetCopied()
boolean isServerMessage()
HornetQBuffer getEncodedBuffer()
int getHeadersAndPropertiesEncodeSize()
HornetQBuffer getWholeBuffer()
void encodeHeadersAndProperties(HornetQBuffer buffer)
void decodeHeadersAndProperties(HornetQBuffer buffer)
BodyEncoder getBodyEncoder() throws HornetQException
HornetQException
InputStream getBodyInputStream()
void setAddressTransient(SimpleString address)
TypedProperties getTypedProperties()
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.