org.hornetq.core.persistence.impl.journal

Class LargeServerMessageImpl

java.lang.Object

org.hornetq.core.message.impl.MessageImpl

org.hornetq.core.server.impl.ServerMessageImpl

org.hornetq.core.persistence.impl.journal.LargeServerMessageImpl

All Implemented Interfaces:

Message, EncodingSupport, MessageInternal, ReplicatedLargeMessage, LargeServerMessage, ServerMessage

public final class LargeServerMessageImpl
extends ServerMessageImpl
implements LargeServerMessage

A LargeServerMessageImpl

Author:

Clebert Suconic

Field Summary

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

address, BODY_OFFSET, bodyBuffer, buffer, BUFFER_HEADER_SPACE, bufferValid, durable, 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_ORIGINAL_QUEUE, HDR_SCHEDULED_DELIVERY_TIME, MAP_TYPE, OBJECT_TYPE, STREAM_TYPE, TEXT_TYPE

Constructor Summary

Constructors

Constructor and Description
LargeServerMessageImpl(JournalStorageManager storageManager)

Method Summary

Methods

Modifier and Type	Method and Description
void	addBytes(byte[] bytes)
protected void	closeFile()
ServerMessage	copy()
ServerMessage	copy(long newID) The copy of the file itself will be done later by finishCopy()
void	copyFrom(SequentialFile fileSource)
protected SequentialFile	createFile()
void	decode(HornetQBuffer buffer1)
void	decrementDelayDeletionCount()
int	decrementRefCount()
void	deleteFile()
void	encode(HornetQBuffer buffer1)
void	encodeBody(HornetQBuffer bufferOut, BodyEncoder context, int size)
protected void	finalize()
void	finishCopy()
BodyEncoder	getBodyEncoder()
int	getEncodeSize() Returns the size of the encoded message.
SequentialFile	getFile()
int	getMemoryEstimate()
long	getPendingRecordID()
void	incrementDelayDeletionCount()
boolean	isLargeMessage() Returns whether this message is a large message or a regular message.
protected void	openFile()
void	releaseResources() Close the files if opened
void	setOriginalHeaders(ServerMessage other, MessageReference originalReference, boolean expiry)
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

createReference, decrementDurableRefCount, encodeMessageIDToBuffer, forceAddress, getBodyInputStream, getDuplicateIDBytes, getDuplicateProperty, getPagingStore, getRefCount, hasInternalProperties, incrementDurableRefCount, incrementRefCount, isServerMessage, makeCopyForExpiryOrDLA, setMessageID, setPagingStore, storeIsPaging

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

bodyChanged, checkCompletion, checkCopy, containsProperty, containsProperty, copyHeadersAndProperties, createBody, decodeFromBuffer, decodeHeadersAndProperties, encodeHeadersAndProperties, getAddress, getBodyBuffer, getBodyBufferCopy, getBooleanProperty, getBooleanProperty, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getDoubleProperty, getDoubleProperty, getEncodedBuffer, 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, putCharProperty, putCharProperty, 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, getClass, hashCode, notify, notifyAll, wait, wait, wait

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

createReference, decrementDurableRefCount, encodeMessageIDToBuffer, forceAddress, getDuplicateIDBytes, getDuplicateProperty, getPagingStore, getRefCount, hasInternalProperties, incrementDurableRefCount, incrementRefCount, makeCopyForExpiryOrDLA, setMessageID, setPagingStore, storeIsPaging

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

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

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

containsProperty, containsProperty, getAddress, getBodyBuffer, getBodyBufferCopy, 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, putCharProperty, putCharProperty, 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.replication.ReplicatedLargeMessage

setDurable, setMessageID

Constructor Detail

LargeServerMessageImpl

public LargeServerMessageImpl(JournalStorageManager storageManager)

Method Detail

setPendingRecordID

public void setPendingRecordID(long pendingRecordID)

Specified by:

setPendingRecordID in interface LargeServerMessage

Parameters:

pendingRecordID -

getPendingRecordID

public long getPendingRecordID()

Specified by:

getPendingRecordID in interface LargeServerMessage

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

addBytes

public void addBytes(byte[] bytes)
              throws Exception

Specified by:

addBytes in interface ReplicatedLargeMessage

Specified by:

addBytes in interface LargeServerMessage

Throws:

Exception

See Also:

LargeServerMessage.addBytes(byte[])

encodeBody

public void encodeBody(HornetQBuffer bufferOut,
              BodyEncoder context,
              int size)

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

encode

public void encode(HornetQBuffer buffer1)

Specified by:

encode in interface EncodingSupport

Overrides:

encode in class MessageImpl

decode

public void decode(HornetQBuffer buffer1)

Specified by:

decode in interface EncodingSupport

Overrides:

decode in class MessageImpl

incrementDelayDeletionCount

public void incrementDelayDeletionCount()

Specified by:

incrementDelayDeletionCount in interface LargeServerMessage

decrementDelayDeletionCount

public void decrementDelayDeletionCount()
                                 throws Exception

Specified by:

decrementDelayDeletionCount in interface LargeServerMessage

Throws:

Exception

getBodyEncoder

public BodyEncoder getBodyEncoder()
                           throws HornetQException

Specified by:

getBodyEncoder in interface MessageInternal

Overrides:

getBodyEncoder in class MessageImpl

Throws:

HornetQException

decrementRefCount

public int decrementRefCount()
                      throws Exception

Specified by:

decrementRefCount in interface ServerMessage

Overrides:

decrementRefCount in class ServerMessageImpl

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

deleteFile

public void deleteFile()
                throws Exception

Specified by:

deleteFile in interface ReplicatedLargeMessage

Specified by:

deleteFile in interface LargeServerMessage

Throws:

Exception

See Also:

LargeServerMessage.deleteFile()

getMemoryEstimate

public int getMemoryEstimate()

Specified by:

getMemoryEstimate in interface ServerMessage

Overrides:

getMemoryEstimate in class ServerMessageImpl

releaseResources

public void releaseResources()

Description copied from interface: LargeServerMessage

Close the files if opened

Specified by:

releaseResources in interface ReplicatedLargeMessage

Specified by:

releaseResources in interface LargeServerMessage

See Also:

LargeServerMessage.releaseResources()

setOriginalHeaders

public void setOriginalHeaders(ServerMessage other,
                      MessageReference originalReference,
                      boolean expiry)

Specified by:

setOriginalHeaders in interface ServerMessage

Overrides:

setOriginalHeaders in class ServerMessageImpl

copy

public ServerMessage copy()

Specified by:

copy in interface ServerMessage

Overrides:

copy in class ServerMessageImpl

copyFrom

public void copyFrom(SequentialFile fileSource)
              throws Exception

Throws:

Exception

finishCopy

public void finishCopy()
                throws Exception

Specified by:

finishCopy in interface ServerMessage

Overrides:

finishCopy in class ServerMessageImpl

Throws:

Exception

copy

public ServerMessage copy(long newID)

The copy of the file itself will be done later by finishCopy()

Specified by:

copy in interface ServerMessage

Overrides:

copy in class ServerMessageImpl

getFile

public SequentialFile getFile()
                       throws HornetQException

Specified by:

getFile in interface LargeServerMessage

Returns:

Throws:

HornetQException

toString

public String toString()

Overrides:

toString in class ServerMessageImpl

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

createFile

protected SequentialFile createFile()

openFile

protected void openFile()
                 throws Exception

Throws:

Exception

closeFile

protected void closeFile()
                  throws Exception

Throws:

Exception