org.apache.activemq.artemis.core.persistence.impl.journal

Class LargeServerMessageImpl

java.lang.Object

org.apache.activemq.artemis.core.message.impl.MessageImpl

org.apache.activemq.artemis.core.server.impl.ServerMessageImpl

org.apache.activemq.artemis.core.persistence.impl.journal.LargeServerMessageImpl

All Implemented Interfaces:

org.apache.activemq.artemis.api.core.Message, org.apache.activemq.artemis.core.journal.EncodingSupport, org.apache.activemq.artemis.core.message.impl.MessageInternal, ReplicatedLargeMessage, LargeServerMessage, ServerMessage

public final class LargeServerMessageImpl
extends ServerMessageImpl
implements LargeServerMessage

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.message.impl.MessageImpl

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

Fields inherited from interface org.apache.activemq.artemis.api.core.Message

BYTES_TYPE, DEFAULT_TYPE, HDR_ACTUAL_EXPIRY_TIME, HDR_CONTENT_TYPE, 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, HDR_VALIDATED_USER, MAP_TYPE, OBJECT_TYPE, STREAM_TYPE, TEXT_TYPE

Constructor Summary

Constructors

Constructor and Description
LargeServerMessageImpl(JournalStorageManager storageManager)

Method Summary

Modifier and Type	Method and Description
void	addBytes(byte[] bytes)
protected void	closeFile()
ServerMessage	copy()
ServerMessage	copy(long newID)
protected org.apache.activemq.artemis.core.io.SequentialFile	createFile()
void	decode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer1)
void	decrementDelayDeletionCount()
int	decrementRefCount()
void	deleteFile()
void	encode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer1)
void	encodeBody(org.apache.activemq.artemis.api.core.ActiveMQBuffer bufferOut, org.apache.activemq.artemis.core.message.BodyEncoder context, int size)
protected void	finalize()
org.apache.activemq.artemis.core.message.BodyEncoder	getBodyEncoder()
int	getEncodeSize()
org.apache.activemq.artemis.core.io.SequentialFile	getFile()
int	getMemoryEstimate()
long	getPendingRecordID()
void	incrementDelayDeletionCount()
boolean	isLargeMessage()
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()
void	validateFile()

Methods inherited from class org.apache.activemq.artemis.core.server.impl.ServerMessageImpl

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

Methods inherited from class org.apache.activemq.artemis.core.message.impl.MessageImpl

bodyChanged, bodyToString, checkCompletion, containsProperty, containsProperty, copyHeadersAndProperties, createBody, decodeFromBuffer, decodeHeadersAndProperties, encodeHeadersAndProperties, equals, getAddress, getBodyBuffer, getBodyBufferDuplicate, 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, hashCode, 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, setAddress, setAddressTransient, setDurable, setExpiration, setPriority, setTimestamp, setType, setUserID, toMap, toPropertyMap, writeBodyBufferBytes, writeBodyBufferString

Methods inherited from class java.lang.Object

clone, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.core.server.ServerMessage

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

Methods inherited from interface org.apache.activemq.artemis.core.message.impl.MessageInternal

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

Methods inherited from interface org.apache.activemq.artemis.api.core.Message

containsProperty, containsProperty, getAddress, getBodyBuffer, getBodyBufferDuplicate, 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, toPropertyMap, writeBodyBufferBytes, writeBodyBufferString

Methods inherited from interface org.apache.activemq.artemis.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(org.apache.activemq.artemis.api.core.ActiveMQBuffer bufferOut,
                       org.apache.activemq.artemis.core.message.BodyEncoder context,
                       int size)

getEncodeSize

public int getEncodeSize()

Specified by:

getEncodeSize in interface org.apache.activemq.artemis.api.core.Message

Specified by:

getEncodeSize in interface org.apache.activemq.artemis.core.journal.EncodingSupport

Overrides:

getEncodeSize in class org.apache.activemq.artemis.core.message.impl.MessageImpl

encode

public void encode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer1)

Specified by:

encode in interface org.apache.activemq.artemis.core.journal.EncodingSupport

Overrides:

encode in class org.apache.activemq.artemis.core.message.impl.MessageImpl

decode

public void decode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer1)

Specified by:

decode in interface org.apache.activemq.artemis.core.journal.EncodingSupport

Overrides:

decode in class org.apache.activemq.artemis.core.message.impl.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 org.apache.activemq.artemis.core.message.BodyEncoder getBodyEncoder()
                                                                    throws org.apache.activemq.artemis.api.core.ActiveMQException

Specified by:

getBodyEncoder in interface org.apache.activemq.artemis.core.message.impl.MessageInternal

Overrides:

getBodyEncoder in class org.apache.activemq.artemis.core.message.impl.MessageImpl

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

decrementRefCount

public int decrementRefCount()
                      throws Exception

Specified by:

decrementRefCount in interface ServerMessage

Overrides:

decrementRefCount in class ServerMessageImpl

Throws:

Exception

isLargeMessage

public boolean isLargeMessage()

Specified by:

isLargeMessage in interface org.apache.activemq.artemis.api.core.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

copy

public ServerMessage copy(long newID)

Specified by:

copy in interface ServerMessage

Overrides:

copy in class ServerMessageImpl

getFile

public org.apache.activemq.artemis.core.io.SequentialFile getFile()
                                                           throws org.apache.activemq.artemis.api.core.ActiveMQException

Specified by:

getFile in interface LargeServerMessage

Returns:

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

toString

public String toString()

Overrides:

toString in class ServerMessageImpl

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

validateFile

public void validateFile()
                  throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

createFile

protected org.apache.activemq.artemis.core.io.SequentialFile createFile()

openFile

protected void openFile()
                 throws Exception

Throws:

Exception

closeFile

protected void closeFile()
                  throws Exception

Throws:

Exception