org.apache.activemq.artemis.core.persistence

Interface OperationContext

All Superinterfaces:

IOCallback, IOCompletion

All Known Implementing Classes:

OperationContextImpl

public interface OperationContext
extends IOCompletion

This represents a set of operations done as part of replication.

When the entire set is done, a group of Runnables can be executed.

Method Summary

Modifier and Type	Method and Description
void	executeOnCompletion(IOCallback runnable) Execute the task when all IO operations are complete, Or execute it immediately if nothing is pending.
void	executeOnCompletion(IOCallback runnable, boolean storeOnly) Execute the task when all IO operations are complete, Or execute it immediately if nothing is pending.
void	pageSyncDone()
void	pageSyncLineUp()
void	replicationDone()
void	replicationLineUp()
void	waitCompletion()
boolean	waitCompletion(long timeout)

Methods inherited from interface org.apache.activemq.artemis.core.journal.IOCompletion

storeLineUp

Methods inherited from interface org.apache.activemq.artemis.core.io.IOCallback

done, onError

Method Detail

executeOnCompletion

void executeOnCompletion(IOCallback runnable,
                         boolean storeOnly)

Execute the task when all IO operations are complete, Or execute it immediately if nothing is pending.

Parameters:

runnable - the tas to be executed.

storeOnly - There are tasks that won't need to wait on replication or paging and will need to be completed as soon as the response from the journal is received. An example would be the DuplicateCache

executeOnCompletion

void executeOnCompletion(IOCallback runnable)

Execute the task when all IO operations are complete, Or execute it immediately if nothing is pending.

Parameters:

runnable - the tas to be executed.

replicationLineUp

void replicationLineUp()

replicationDone

void replicationDone()

pageSyncLineUp

void pageSyncLineUp()

pageSyncDone

void pageSyncDone()

waitCompletion

void waitCompletion()
             throws Exception

Throws:

Exception

waitCompletion

boolean waitCompletion(long timeout)
                throws Exception

Parameters:

timeout - in milliseconds

Returns:

Throws:

Exception