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

Class LargeServerMessageInSync

java.lang.Object

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

All Implemented Interfaces:

ReplicatedLargeMessage

public final class LargeServerMessageInSync
extends Object
implements ReplicatedLargeMessage

Constructor Summary

Constructors

Constructor and Description
LargeServerMessageInSync(StorageManager storageManager)

Method Summary

Modifier and Type	Method and Description
void	addBytes(byte[] bytes)
void	deleteFile()
SequentialFile	getSyncFile()
void	joinSyncedData(ByteBuffer buffer)
void	releaseResources()
Message	setDurable(boolean durable)
Message	setMessageID(long id)

Methods inherited from class java.lang.Object

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

Constructor Detail

LargeServerMessageInSync

public LargeServerMessageInSync(StorageManager storageManager)

Parameters:

storageManager -

Method Detail

joinSyncedData

public void joinSyncedData(ByteBuffer buffer)
                    throws Exception

Throws:

Exception

getSyncFile

public SequentialFile getSyncFile()
                           throws ActiveMQException

Throws:

ActiveMQException

setDurable

public Message setDurable(boolean durable)

Specified by:

setDurable in interface ReplicatedLargeMessage

See Also:

Message.setDurable(boolean)

setMessageID

public Message setMessageID(long id)

Specified by:

setMessageID in interface ReplicatedLargeMessage

See Also:

ServerMessage.setMessageID(long)

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface ReplicatedLargeMessage

See Also:

LargeServerMessage.releaseResources()

deleteFile

public void deleteFile()
                throws Exception

Specified by:

deleteFile in interface ReplicatedLargeMessage

Throws:

Exception

See Also:

LargeServerMessage.deleteFile()

addBytes

public void addBytes(byte[] bytes)
              throws Exception

Specified by:

addBytes in interface ReplicatedLargeMessage

Throws:

Exception

See Also:

LargeServerMessage.addBytes(byte[])