public class NullStorageLargeServerMessage extends ServerMessageImpl implements LargeServerMessage
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
Constructor and Description |
---|
NullStorageLargeServerMessage() |
Modifier and Type | Method and Description |
---|---|
void |
addBytes(byte[] bytes) |
void |
complete() |
void |
decrementDelayDeletionCount() |
void |
deleteFile() |
int |
getEncodeSize()
Returns the size of the encoded message.
|
long |
getPendingRecordID() |
void |
incrementDelayDeletionCount() |
boolean |
isComplete() |
boolean |
isFileExists() |
boolean |
isLargeMessage()
Returns whether this message is a large message or a regular message.
|
void |
releaseResources()
Close the files if opened
|
void |
setComplete(boolean isComplete) |
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) |
String |
toString() |
copy, copy, createReference, decrementDurableRefCount, decrementRefCount, encodeMessageIDToBuffer, finishCopy, getBodyInputStream, getDuplicateIDBytes, getDuplicateProperty, getMemoryEstimate, getPagingStore, getRefCount, hasInternalProperties, incrementDurableRefCount, incrementRefCount, isServerMessage, makeCopyForExpiryOrDLA, setMessageID, setOriginalHeaders, setPagingStore, storeIsPaging
bodyChanged, checkCopy, containsProperty, containsProperty, copyHeadersAndProperties, createBody, decode, decodeFromBuffer, decodeHeadersAndProperties, encode, encodeHeadersAndProperties, getAddress, getBodyBuffer, getBodyEncoder, getBooleanProperty, getBooleanProperty, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getDoubleProperty, getDoubleProperty, getEncodedBuffer, 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
copy, copy, createReference, decrementDurableRefCount, decrementRefCount, encodeMessageIDToBuffer, finishCopy, 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, getBooleanProperty, getBooleanProperty, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getDoubleProperty, getDoubleProperty, 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
public void releaseResources()
LargeServerMessage
releaseResources
in interface LargeServerMessage
public void addBytes(byte[] bytes)
addBytes
in interface LargeServerMessage
public void deleteFile() throws Exception
deleteFile
in interface LargeServerMessage
Exception
public boolean isLargeMessage()
Message
isLargeMessage
in interface Message
isLargeMessage
in class ServerMessageImpl
public boolean isComplete()
public void setComplete(boolean isComplete)
public boolean isFileExists() throws Exception
isFileExists
in interface LargeServerMessage
Exception
public void decrementDelayDeletionCount()
decrementDelayDeletionCount
in interface LargeServerMessage
public void incrementDelayDeletionCount()
incrementDelayDeletionCount
in interface LargeServerMessage
public int getEncodeSize()
Message
getEncodeSize
in interface Message
getEncodeSize
in interface EncodingSupport
getEncodeSize
in class MessageImpl
public String toString()
toString
in class ServerMessageImpl
public void setPaged()
LargeServerMessage
setPaged
in interface LargeServerMessage
public void setPendingRecordID(long pendingRecordID)
setPendingRecordID
in interface LargeServerMessage
public long getPendingRecordID()
getPendingRecordID
in interface LargeServerMessage
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.