Package 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	Description
void	addBytes(byte[] bytes)
default void	addBytes(ActiveMQBuffer bytes)
void	addBytes(ActiveMQBuffer bytes, boolean initialHeader)
void	deleteFile()
SequentialFile	getAppendFile()	This will return the File suitable for appending the message
LargeBody	getLargeBody()
LargeBodyReader	getLargeBodyReader()
long	getMessageID()
StorageManager	getStorageManager()
boolean	isOpen()
void	releaseResources(boolean sync, boolean sendEvent)	Close the files if opened
void	setPaged()
void	setStorageManager(StorageManager storageManager)
Message	toMessage()

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

getMessage, setDurable, setMessageID

Method Details

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

releaseResources

void releaseResources(boolean sync,
 boolean sendEvent)

Close the files if opened

Specified by:

releaseResources in interface ReplicatedLargeMessage

See Also:

• releaseResources(boolean,boolean)

isOpen

boolean isOpen()

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

Throws:

ActiveMQException

getLargeBodyReader

LargeBodyReader getLargeBodyReader()
                            throws ActiveMQException

Throws:

ActiveMQException

getLargeBody

LargeBody getLargeBody()

setStorageManager

void setStorageManager(StorageManager storageManager)