org.hornetq.core.persistence.impl.nullpm

Class NullStorageLargeServerMessage

java.lang.Object

org.hornetq.core.message.impl.MessageImpl

org.hornetq.core.server.impl.ServerMessageImpl

org.hornetq.core.persistence.impl.nullpm.NullStorageLargeServerMessage

All Implemented Interfaces:

Message, EncodingSupport, MessageInternal, LargeServerMessage, ServerMessage

public class NullStorageLargeServerMessage
extends ServerMessageImpl
implements LargeServerMessage

A NullStorageLargeServerMessage

Author:

Clebert Suconic Created 30-Sep-08 1:51:42 PM

Field Summary

Fields inherited from class org.hornetq.core.message.impl.MessageImpl

address, BODY_OFFSET, bodyBuffer, buffer, BUFFER_HEADER_SPACE, bufferValid, durable, expiration, HDR_BRIDGE_DUPLICATE_ID, HDR_ROUTE_TO_IDS, messageID, priority, properties, timestamp, type

Fields inherited from interface org.hornetq.api.core.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

Constructor Summary

Constructors

Constructor and Description
NullStorageLargeServerMessage()

Method Summary

Methods

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()

Methods inherited from class org.hornetq.core.server.impl.ServerMessageImpl

copy, copy, createReference, decrementDurableRefCount, decrementRefCount, encodeMessageIDToBuffer, finishCopy, getBodyInputStream, getDuplicateIDBytes, getDuplicateProperty, getMemoryEstimate, getPagingStore, getRefCount, hasInternalProperties, incrementDurableRefCount, incrementRefCount, isServerMessage, makeCopyForExpiryOrDLA, setMessageID, setOriginalHeaders, setPagingStore, storeIsPaging

Methods inherited from class org.hornetq.core.message.impl.MessageImpl

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.hornetq.core.server.ServerMessage

copy, copy, createReference, decrementDurableRefCount, decrementRefCount, encodeMessageIDToBuffer, finishCopy, getDuplicateIDBytes, getDuplicateProperty, getMemoryEstimate, getPagingStore, getRefCount, hasInternalProperties, incrementDurableRefCount, incrementRefCount, makeCopyForExpiryOrDLA, setMessageID, setOriginalHeaders, setPagingStore, storeIsPaging

Methods inherited from interface org.hornetq.core.message.impl.MessageInternal

bodyChanged, checkCopy, decodeFromBuffer, decodeHeadersAndProperties, encodeHeadersAndProperties, getBodyEncoder, getBodyInputStream, getEncodedBuffer, getEndOfBodyPosition, getEndOfMessagePosition, getHeadersAndPropertiesEncodeSize, getTypedProperties, getWholeBuffer, isServerMessage, resetCopied, setAddressTransient

Methods inherited from interface org.hornetq.api.core.Message

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

Methods inherited from interface org.hornetq.core.journal.EncodingSupport

decode, encode

Constructor Detail

NullStorageLargeServerMessage

public NullStorageLargeServerMessage()

Method Detail

releaseResources

public void releaseResources()

Description copied from interface: LargeServerMessage

Close the files if opened

Specified by:

releaseResources in interface LargeServerMessage

addBytes

public void addBytes(byte[] bytes)

Specified by:

addBytes in interface LargeServerMessage

deleteFile

public void deleteFile()
                throws Exception

Specified by:

deleteFile in interface LargeServerMessage

Throws:

Exception

complete

public void complete()
              throws Exception

Throws:

Exception

isLargeMessage

public boolean isLargeMessage()

Description copied from interface: Message

Returns whether this message is a large message or a regular message.

Specified by:

isLargeMessage in interface Message

Overrides:

isLargeMessage in class ServerMessageImpl

isComplete

public boolean isComplete()

setComplete

public void setComplete(boolean isComplete)

isFileExists

public boolean isFileExists()
                     throws Exception

Specified by:

isFileExists in interface LargeServerMessage

Throws:

Exception

decrementDelayDeletionCount

public void decrementDelayDeletionCount()

Specified by:

decrementDelayDeletionCount in interface LargeServerMessage

incrementDelayDeletionCount

public void incrementDelayDeletionCount()

Specified by:

incrementDelayDeletionCount in interface LargeServerMessage

getEncodeSize

public int getEncodeSize()

Description copied from interface: Message

Returns the size of the encoded message.

Specified by:

getEncodeSize in interface Message

Specified by:

getEncodeSize in interface EncodingSupport

Overrides:

getEncodeSize in class MessageImpl

toString

public String toString()

Overrides:

toString in class ServerMessageImpl

setPaged

public void setPaged()

Description copied from interface: LargeServerMessage

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

Specified by:

setPaged in interface LargeServerMessage

setPendingRecordID

public void setPendingRecordID(long pendingRecordID)

Specified by:

setPendingRecordID in interface LargeServerMessage

getPendingRecordID

public long getPendingRecordID()

Specified by:

getPendingRecordID in interface LargeServerMessage