Package 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, memoryEstimate, messageID, messageIDPosition, paged, priority, properties, timestamp, type, writableBuffer

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

AMQP_PROPERTY_PREDICATE, 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_INGRESS_TIMESTAMP, HDR_LARGE_BODY_SIZE, HDR_LARGE_COMPRESSED, HDR_LAST_VALUE_NAME, HDR_ORIG_MESSAGE_ID, HDR_ORIG_ROUTING_TYPE, 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, PREFIX_AMQP_ANNOTATIONS, STREAM_TYPE, TEXT_TYPE

Constructor Summary

Constructors

Constructor	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	Description
void	addBytes(byte[] bytes)
void	addBytes(ActiveMQBuffer bytes, boolean initialHeader)
static Message	checkLargeMessage(Message message, StorageManager storageManager)	This will check if a regular message needs to be converted as large message
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)
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()
Message	getMessage()
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. for LargeMessages this will contain whatever is needed to encode properties and the body size of large messages.
boolean	isLargeMessage()
boolean	isOpen()
boolean	isServerMessage()	We are really interested if this is a LargeServerMessage.
void	referenceOriginalMessage(Message original, SimpleString originalQueue)
protected void	releaseComplete()
void	releaseResources(boolean sync, boolean sendEvent)	Close the files if opened
LargeServerMessageImpl	setMessageID(long messageID)
void	setPaged()
void	setStorageManager(StorageManager storageManager)
Message	toMessage()
String	toString()

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

checkEncode, clearAMQPProperties, 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, getOwner, getPersister, getPersistSize, getPriority, getProperties, getPropertyNames, getProtocolName, getReplyTo, getRoutingType, getScheduledDeliveryTime, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringBody, getStringProperty, getStringProperty, getTimestamp, getType, getUserID, getValidatedUserID, hasScheduledDeliveryTime, initBuffer, internalSetMessageID, isDurable, isPaged, 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, receiveBuffer_1X, reloadPersistence, removeAnnotation, removeProperty, removeProperty, searchProperty, sendBuffer, sendBuffer_1X, setAddress, setAddress, setBuffer, setCorrelationID, setDurable, setExpiration, setGroupID, setGroupID, setGroupSequence, setLastValueProperty, setOwner, setPriority, setReplyTo, setRoutingType, setScheduledDeliveryTime, setTimestamp, setType, setUserID, setUserID, setValidatedUserID, toCompositeData, toCore, toCore

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

counterString, debugLocations, deferredDebug, deferredDebug, deferredDebug, disableErrorCheck, durableDown, durableUp, getDurableCount, getParentRef, getRefCount, getUsage, getUserContext, isRefDebugEnabled, isRefTraceEnabled, isReleased, onDown, onUp, refDown, refUp, registerDebug, released, setParentRef, setUserContext, 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.api.core.ICoreMessage

isConfirmed, setConfirmed, toMap

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

addBytes, getMessageID

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

acceptsConsumer, copy, durableDown, durableUp, getAnnotationString, getBrokerProperty, getConnectionID, getDuplicateIDBytes, getDurableCount, getExtraBytesProperty, getIngressTimestamp, getObjectPropertyForFilter, getOriginalEstimate, getRefCount, getUsage, getUserContext, isExpired, putExtraBytesProperty, reencode, refDown, refUp, rejectConsumer, removeExtraBytesProperty, routed, setAnnotation, setBrokerProperty, setConnectionID, setIngressTimestamp, setUserContext, toMap, toPropertyMap, toPropertyMap, usageDown, usageUp

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

setDurable

Constructor Details

LargeServerMessageImpl

public LargeServerMessageImpl(StorageManager storageManager)

LargeServerMessageImpl

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

Copy constructor

LargeServerMessageImpl

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

Method Details

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

setMessageID

public LargeServerMessageImpl setMessageID(long messageID)

Specified by:

setMessageID in interface Message

Specified by:

setMessageID in interface ReplicatedLargeMessage

Overrides:

setMessageID in class CoreMessage

See Also:

• ReplicatedLargeMessage.setMessageID(long)

getMessage

public Message getMessage()

Specified by:

getMessage in interface ReplicatedLargeMessage

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

setPaged

public void setPaged()

Specified by:

setPaged in interface LargeServerMessage

Specified by:

setPaged in interface Message

Overrides:

setPaged in class CoreMessage

addBytes

public void addBytes(byte[] bytes)
              throws Exception

Specified by:

addBytes in interface LargeServerMessage

Specified by:

addBytes in interface ReplicatedLargeMessage

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

Returns:

the size of the encoded message

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

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

Returns:

a new Buffer slicing the current Body

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

Returns:

the length in bytes of the body buffer

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 LargeServerMessage

Specified by:

deleteFile in interface ReplicatedLargeMessage

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,
 boolean sendEvent)

Description copied from interface: LargeServerMessage

Close the files if opened

Specified by:

releaseResources in interface LargeServerMessage

Specified by:

releaseResources in interface ReplicatedLargeMessage

See Also:

• LargeServerMessage.releaseResources(boolean,boolean)

isOpen

public boolean isOpen()

Specified by:

isOpen in interface LargeServerMessage

referenceOriginalMessage

public void referenceOriginalMessage(Message original,
 SimpleString 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

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

Throws:

ActiveMQException

toString

public String toString()

Overrides:

toString in class CoreMessage