org.apache.activemq.artemis.core.server

Interface LargeServerMessage

All Superinterfaces:

ReplicatedLargeMessage

All Known Subinterfaces:

CoreLargeServerMessage

All Known Implementing Classes:

LargeServerMessageImpl

public interface LargeServerMessage
extends ReplicatedLargeMessage

Method Summary

Modifier and Type	Method and Description
default void	addBytes(ActiveMQBuffer bytes)
void	addBytes(ActiveMQBuffer bytes, boolean initialHeader)
void	addBytes(byte[] bytes)
void	deleteFile()
SequentialFile	getAppendFile() This will return the File suitable for appending the message
LargeBody	getLargeBody()
LargeBodyReader	getLargeBodyReader()
long	getMessageID()
StorageManager	getStorageManager()
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	setStorageManager(StorageManager storageManager)
Message	toMessage()
void	validateFile()

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

clearPendingRecordID, getPendingRecordID, hasPendingRecord, setDurable, setMessageID, setPendingRecordID

Method Detail

toMessage

Message toMessage()

getStorageManager

StorageManager getStorageManager()

addBytes

void addBytes(byte[] bytes)
       throws Exception

Specified by:

addBytes in interface ReplicatedLargeMessage

Throws:

Exception

See Also:

addBytes(byte[])

addBytes

default void addBytes(ActiveMQBuffer bytes)
               throws Exception

Throws:

Exception

addBytes

void addBytes(ActiveMQBuffer bytes,
              boolean initialHeader)
       throws Exception

Throws:

Exception

getMessageID

long getMessageID()

setPaged

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

releaseResources

void releaseResources(boolean sync)

Close the files if opened

Specified by:

releaseResources in interface ReplicatedLargeMessage

See Also:

releaseResources(boolean)

deleteFile

void deleteFile()
         throws Exception

Specified by:

deleteFile in interface ReplicatedLargeMessage

Throws:

Exception

See Also:

deleteFile()

getAppendFile

SequentialFile getAppendFile()
                      throws ActiveMQException

This will return the File suitable for appending the message

Returns:

Throws:

ActiveMQException

getLargeBodyReader

LargeBodyReader getLargeBodyReader()
                            throws ActiveMQException

Throws:

ActiveMQException

getLargeBody

LargeBody getLargeBody()

setStorageManager

void setStorageManager(StorageManager storageManager)

validateFile

void validateFile()
           throws ActiveMQException

Throws:

ActiveMQException