org.hornetq.core.persistence.impl.journal

Class OperationContextImpl

java.lang.Object

org.hornetq.core.persistence.impl.journal.OperationContextImpl

All Implemented Interfaces:

AIOCallback, IOAsyncTask, IOCompletion, OperationContext

public class OperationContextImpl
extends Object
implements OperationContext

Each instance of OperationContextImpl is associated with an executor (usually an ordered Executor). Tasks are hold until the operations are complete and executed in the natural order as soon as the operations are returned from replication and storage. If there are no pending IO operations, the tasks are just executed at the callers thread without any context switch. So, if you are doing operations that are not dependent on IO (e.g NonPersistentMessages) you wouldn't have any context switch.

Author:

Clebert Suconic

Constructor Summary

Constructors

Constructor and Description
OperationContextImpl(Executor executor)

Method Summary

Methods

Modifier and Type	Method and Description
static void	clearContext()
void	complete()
void	done() Method for sync notifications.
void	executeOnCompletion(IOAsyncTask completion) Execute the task when all IO operations are complete, Or execute it immediately if nothing is pending.
static OperationContext	getContext()
static OperationContext	getContext(ExecutorFactory executorFactory)
void	onError(int errorCode, String errorMessage) Method for error notifications.
void	pageSyncDone()
void	pageSyncLineUp()
void	replicationDone()
void	replicationLineUp()
static void	setContext(OperationContext context)
void	storeLineUp()
String	toString()
void	waitCompletion()
boolean	waitCompletion(long timeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperationContextImpl

public OperationContextImpl(Executor executor)

Method Detail

clearContext

public static void clearContext()

getContext

public static final OperationContext getContext()

getContext

public static OperationContext getContext(ExecutorFactory executorFactory)

setContext

public static void setContext(OperationContext context)

pageSyncLineUp

public void pageSyncLineUp()

Specified by:

pageSyncLineUp in interface OperationContext

pageSyncDone

public void pageSyncDone()

Specified by:

pageSyncDone in interface OperationContext

storeLineUp

public void storeLineUp()

Specified by:

storeLineUp in interface IOCompletion

replicationLineUp

public void replicationLineUp()

Specified by:

replicationLineUp in interface OperationContext

replicationDone

public void replicationDone()

Specified by:

replicationDone in interface OperationContext

executeOnCompletion

public void executeOnCompletion(IOAsyncTask completion)

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

done

public void done()

Description copied from interface: AIOCallback

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 AIOCallback

complete

public void complete()

onError

public void onError(int errorCode,
           String errorMessage)

Description copied from interface: AIOCallback

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 AIOCallback

waitCompletion

public void waitCompletion()
                    throws Exception

Specified by:

waitCompletion in interface OperationContext

Throws:

Exception

waitCompletion

public boolean waitCompletion(long timeout)
                       throws InterruptedException,
                              HornetQException

Specified by:

waitCompletion in interface OperationContext

Parameters:

timeout - in milliseconds

Returns:

Throws:

InterruptedException

HornetQException

toString

public String toString()

Overrides:

toString in class Object