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

Class DummyOperationContext

java.lang.Object

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

All Implemented Interfaces:

IOCallback, IOCompletion, OperationContext

public final class DummyOperationContext
extends Object
implements OperationContext

Constructor Summary

Constructors

Constructor and Description
DummyOperationContext()

Method Summary

Modifier and Type	Method and Description
void	done() Method for sync notifications.
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.
static OperationContext	getInstance()
void	onError(int errorCode, String errorMessage) Method for error notifications.
void	pageSyncDone()
void	pageSyncLineUp()
void	replicationDone()
void	replicationLineUp()
void	storeLineUp()
void	waitCompletion()
boolean	waitCompletion(long timeout)

Methods inherited from class java.lang.Object

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

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

done, onError

Constructor Detail

DummyOperationContext

public DummyOperationContext()

Method Detail

getInstance

public static OperationContext getInstance()

executeOnCompletion

public void executeOnCompletion(IOCallback runnable)

Description copied from interface: OperationContext

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

Specified by:

executeOnCompletion in interface OperationContext

Parameters:

runnable - the tas to be executed.

executeOnCompletion

public void executeOnCompletion(IOCallback runnable,
                                boolean storeOnly)

Description copied from interface: OperationContext

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

Specified by:

executeOnCompletion in interface OperationContext

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

replicationDone

public void replicationDone()

Specified by:

replicationDone in interface OperationContext

replicationLineUp

public void replicationLineUp()

Specified by:

replicationLineUp in interface OperationContext

storeLineUp

public void storeLineUp()

Specified by:

storeLineUp in interface IOCompletion

done

public void done()

Description copied from interface: IOCallback

Method for sync notifications. When this callback method is called, there is a guarantee the data is written on the disk.
Note:Leave this method as soon as possible, or you would be blocking the whole notification thread

Specified by:

done in interface IOCallback

onError

public void onError(int errorCode,
                    String errorMessage)

Description copied from interface: IOCallback

Method for error notifications. Observation: The whole file will be probably failing if this happens. Like, if you delete the file, you will start to get errors for these operations

Specified by:

onError in interface IOCallback

waitCompletion

public void waitCompletion()

Specified by:

waitCompletion in interface OperationContext

waitCompletion

public boolean waitCompletion(long timeout)

Specified by:

waitCompletion in interface OperationContext

Parameters:

timeout - in milliseconds

Returns:

pageSyncLineUp

public void pageSyncLineUp()

Specified by:

pageSyncLineUp in interface OperationContext

pageSyncDone

public void pageSyncDone()

Specified by:

pageSyncDone in interface OperationContext