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

Class LargeServerMessageImpl

java.lang.Object

org.apache.activemq.artemis.api.core.RefCountMessage

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

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

All Implemented Interfaces:

ICoreMessage, Message, ReplicatedLargeMessage, CoreLargeServerMessage, LargeServerMessage

public final class LargeServerMessageImpl
extends CoreMessage
implements CoreLargeServerMessage

Field Summary

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

address, BODY_OFFSET, buffer, BUFFER_HEADER_SPACE, durable, endOfBodyPosition, messageID, messageIDPosition, priority, properties, timestamp, type, writableBuffer

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

BYTES_TYPE, DEFAULT_TYPE, EMBEDDED_TYPE, HDR_ACTUAL_EXPIRY_TIME, HDR_BRIDGE_DUPLICATE_ID, HDR_CONTENT_TYPE, HDR_DUPLICATE_DETECTION_ID, HDR_GROUP_ID, HDR_GROUP_SEQUENCE, HDR_LARGE_BODY_SIZE, HDR_LARGE_COMPRESSED, HDR_LAST_VALUE_NAME, HDR_ORIG_MESSAGE_ID, HDR_ORIGINAL_ADDRESS, HDR_ORIGINAL_QUEUE, HDR_PREFIX, HDR_ROUTE_TO_ACK_IDS, HDR_ROUTE_TO_IDS, HDR_ROUTING_TYPE, HDR_SCALEDOWN_TO_IDS, HDR_SCHEDULED_DELIVERY_TIME, HDR_VALIDATED_USER, INTERNAL_PROPERTY_NAMES_PREDICATE, LARGE_EMBEDDED_TYPE, MAP_TYPE, memoryOffset, OBJECT_TYPE, STREAM_TYPE, TEXT_TYPE

Constructor Summary

Constructors

Constructor and Description
LargeServerMessageImpl(byte type, long id, StorageManager storageManager, SequentialFile fileCopy)
LargeServerMessageImpl(LargeServerMessageImpl copy, TypedProperties properties, SequentialFile fileCopy, long newID) Copy constructor
LargeServerMessageImpl(StorageManager storageManager)

Method Summary

Modifier and Type	Method and Description
void	addBytes(ActiveMQBuffer bytes, boolean initialHeader)
void	addBytes(byte[] bytes)
static Message	checkLargeMessage(Message message, StorageManager storageManager) This will check if a regular message needs to be converted as large message
void	clearPendingRecordID()
Message	copy() It will generate a new instance of the message encode, being a deep copy, new properties, new everything
Message	copy(long newID) It will generate a new instance of the message encode, being a deep copy, new properties, new everything
void	decode(ActiveMQBuffer buffer1)
void	deleteFile()
void	encode(ActiveMQBuffer buffer1)
void	ensureFileExists(boolean toOpen)
SequentialFile	getAppendFile() This will return the File suitable for appending the message
int	getBodyBufferSize() Returns the length in bytes of the body buffer.
long	getBodySize()
int	getEncodeSize() Returns the size of the encoded message.
LargeBody	getLargeBody()
LargeBodyReader	getLargeBodyReader()
int	getMemoryEstimate()
long	getPendingRecordID()
long	getPersistentSize() This is the size of the message when persisted on disk which is used for metrics tracking Note that even if the message itself is not persisted on disk (ie non-durable) this value is still used for metrics tracking If a normal message it will be the encoded message size If a large message it will be encoded message size + large message body size
ActiveMQBuffer	getReadOnlyBodyBuffer() Returns a new Buffer slicing the current Body.
StorageManager	getStorageManager()
long	getWholeMessageSize() Return an estimate of the size of the message on the wire.
boolean	hasPendingRecord()
boolean	isLargeMessage()
boolean	isServerMessage() We are really interested if this is a LargeServerMessage.
void	referenceOriginalMessage(Message original, String originalQueue)
protected void	releaseComplete()
void	releaseResources(boolean sync) Close the files if opened
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)
void	setStorageManager(StorageManager storageManager)
Message	toMessage()
String	toString()
void	validateFile()

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

checkEncode, clearInternalProperties, containsProperty, containsProperty, decodeHeadersAndProperties, encode, encodeHeadersAndProperties, getAddress, getAddressSimpleString, getAnnotation, getBodyBuffer, getBodyInputStream, getBooleanProperty, getBooleanProperty, getBuffer, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getCorrelationID, getDataBuffer, getDoubleProperty, getDoubleProperty, getDuplicateProperty, getEndOfBodyPosition, getExpiration, getFloatProperty, getFloatProperty, getGroupID, getGroupSequence, getHeadersAndPropertiesEncodeSize, getIntProperty, getIntProperty, getLastValueProperty, getLongProperty, getLongProperty, getMessageID, getObjectProperty, getObjectProperty, getPersister, getPersistSize, getPriority, getProperties, getPropertyNames, getReplyTo, getRoutingType, getScheduledDeliveryTime, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getType, getUserID, getValidatedUserID, hasScheduledDeliveryTime, initBuffer, internalSetMessageID, isDurable, messageChanged, moveHeadersAndProperties, persist, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putCharProperty, putCharProperty, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putObjectProperty, putObjectProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, putStringProperty, receiveBuffer_1X, receiveBuffer, reloadPersistence, removeAnnotation, removeProperty, removeProperty, searchProperty, sendBuffer_1X, sendBuffer, setAddress, setAddress, setBuffer, setCorrelationID, setDurable, setExpiration, setGroupID, setGroupID, setGroupSequence, setLastValueProperty, setMessageID, setPriority, setReplyTo, setRoutingType, setScheduledDeliveryTime, setTimestamp, setType, setUserID, setUserID, setValidatedUserID, toCore, toCore

Methods inherited from class org.apache.activemq.artemis.api.core.RefCountMessage

debugRefs, debugString, durableDown, durableUp, getDurableCount, getParentRef, getRefCount, getUsage, refDown, refUp, setParentRef, usageDown, usageUp

Methods inherited from class java.lang.Object

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

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

addBytes, getMessageID

Methods inherited from interface org.apache.activemq.artemis.core.replication.ReplicatedLargeMessage

setDurable, setMessageID

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

toMap

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

acceptsConsumer, copy, durableDown, durableUp, getAnnotationString, getBrokerProperty, getConnectionID, getDuplicateIDBytes, getDurableCount, getExtraBytesProperty, getObjectPropertyForFilter, getRefCount, getUsage, isExpired, putExtraBytesProperty, reencode, refDown, refUp, rejectConsumer, releaseBuffer, removeExtraBytesProperty, setAnnotation, setBrokerProperty, setConnectionID, toPropertyMap, usageDown, usageUp

Constructor Detail

LargeServerMessageImpl

public LargeServerMessageImpl(StorageManager storageManager)

LargeServerMessageImpl

public LargeServerMessageImpl(LargeServerMessageImpl copy,
                              TypedProperties properties,
                              SequentialFile fileCopy,
                              long newID)

Copy constructor

Parameters:

properties -

copy -

fileCopy -

LargeServerMessageImpl

public LargeServerMessageImpl(byte type,
                              long id,
                              StorageManager storageManager,
                              SequentialFile fileCopy)

Method Detail

toMessage

public Message toMessage()

Specified by:

toMessage in interface LargeServerMessage

checkLargeMessage

public static Message checkLargeMessage(Message message,
                                        StorageManager storageManager)
                                 throws Exception

This will check if a regular message needs to be converted as large message

Throws:

Exception

getBodySize

public long getBodySize()
                 throws ActiveMQException

Throws:

ActiveMQException

getStorageManager

public StorageManager getStorageManager()

Specified by:

getStorageManager in interface LargeServerMessage

isServerMessage

public boolean isServerMessage()

Description copied from interface: ICoreMessage

We are really interested if this is a LargeServerMessage.

Specified by:

isServerMessage in interface ICoreMessage

Overrides:

isServerMessage in class CoreMessage

Returns:

getPendingRecordID

public long getPendingRecordID()

Specified by:

getPendingRecordID in interface ReplicatedLargeMessage

clearPendingRecordID

public void clearPendingRecordID()

Specified by:

clearPendingRecordID in interface ReplicatedLargeMessage

hasPendingRecord

public boolean hasPendingRecord()

Specified by:

hasPendingRecord in interface ReplicatedLargeMessage

setPendingRecordID

public void setPendingRecordID(long pendingRecordID)

Specified by:

setPendingRecordID in interface ReplicatedLargeMessage

Parameters:

pendingRecordID -

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[])

addBytes

public void addBytes(ActiveMQBuffer bytes,
                     boolean initialHeader)
              throws Exception

Specified by:

addBytes in interface LargeServerMessage

Throws:

Exception

getEncodeSize

public int getEncodeSize()

Description copied from interface: Message

Returns the size of the encoded message.

Specified by:

getEncodeSize in interface Message

Overrides:

getEncodeSize in class CoreMessage

getWholeMessageSize

public long getWholeMessageSize()

Description copied from interface: Message

Return an estimate of the size of the message on the wire. for LargeMessages this will contain whatever is needed to encode properties and the body size of large messages. For AMQP this will return the whole body size of the message as the body will contain all the data including properties.

Specified by:

getWholeMessageSize in interface Message

Returns:

encode

public void encode(ActiveMQBuffer buffer1)

decode

public void decode(ActiveMQBuffer buffer1)

getLargeBodyReader

public LargeBodyReader getLargeBodyReader()

Specified by:

getLargeBodyReader in interface ICoreMessage

Specified by:

getLargeBodyReader in interface LargeServerMessage

Overrides:

getLargeBodyReader in class CoreMessage

releaseComplete

protected void releaseComplete()

Overrides:

releaseComplete in class RefCountMessage

getReadOnlyBodyBuffer

public ActiveMQBuffer getReadOnlyBodyBuffer()

Description copied from interface: ICoreMessage

Returns a new Buffer slicing the current Body.

Specified by:

getReadOnlyBodyBuffer in interface ICoreMessage

Overrides:

getReadOnlyBodyBuffer in class CoreMessage

getBodyBufferSize

public int getBodyBufferSize()

Description copied from interface: ICoreMessage

Returns the length in bytes of the body buffer.

Specified by:

getBodyBufferSize in interface ICoreMessage

Overrides:

getBodyBufferSize in class CoreMessage

isLargeMessage

public boolean isLargeMessage()

Specified by:

isLargeMessage in interface Message

Overrides:

isLargeMessage in class CoreMessage

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 Message

Overrides:

getMemoryEstimate in class CoreMessage

releaseResources

public void releaseResources(boolean sync)

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

referenceOriginalMessage

public void referenceOriginalMessage(Message original,
                                     String originalQueue)

Specified by:

referenceOriginalMessage in interface Message

setStorageManager

public void setStorageManager(StorageManager storageManager)

Specified by:

setStorageManager in interface LargeServerMessage

copy

public Message copy()

Description copied from interface: Message

It will generate a new instance of the message encode, being a deep copy, new properties, new everything

Specified by:

copy in interface Message

Overrides:

copy in class CoreMessage

getLargeBody

public LargeBody getLargeBody()

Specified by:

getLargeBody in interface LargeServerMessage

copy

public Message copy(long newID)

Description copied from interface: Message

It will generate a new instance of the message encode, being a deep copy, new properties, new everything

Specified by:

copy in interface Message

Overrides:

copy in class CoreMessage

getAppendFile

public SequentialFile getAppendFile()
                             throws ActiveMQException

Description copied from interface: LargeServerMessage

This will return the File suitable for appending the message

Specified by:

getAppendFile in interface LargeServerMessage

Returns:

Throws:

ActiveMQException

getPersistentSize

public long getPersistentSize()
                       throws ActiveMQException

Description copied from interface: Message

This is the size of the message when persisted on disk which is used for metrics tracking Note that even if the message itself is not persisted on disk (ie non-durable) this value is still used for metrics tracking If a normal message it will be the encoded message size If a large message it will be encoded message size + large message body size

Specified by:

getPersistentSize in interface Message

Overrides:

getPersistentSize in class CoreMessage

Returns:

Throws:

ActiveMQException

toString

public String toString()

Overrides:

toString in class CoreMessage

validateFile

public void validateFile()
                  throws ActiveMQException

Specified by:

validateFile in interface LargeServerMessage

Throws:

ActiveMQException

ensureFileExists

public void ensureFileExists(boolean toOpen)
                      throws ActiveMQException

Throws:

ActiveMQException