Package dev.getelements.elements.rt.transact

Class TransactionalSchedulerContext

java.lang.Object

dev.getelements.elements.rt.transact.TransactionalSchedulerContext

All Implemented Interfaces:

SchedulerContext

public class TransactionalSchedulerContext
extends Object
implements SchedulerContext

Constructor Summary

Constructors

Constructor	Description
TransactionalSchedulerContext()

Method Summary

Modifier and Type	Method	Description
TransactionalResourceServicePersistence	getPersistence()
ResourceService	getResourceService()
SimpleSchedulerContext	getSimpleSchedulerContext()
void	resume(TaskId taskId, Object... results)	Resumes the supplied task with the TaskId supplying multiple results to the destination.
void	resumeFromNetwork(TaskId taskId, Object result)	Resumes a task that was waiting on a network call.
void	resumeTaskAfterDelay(TaskId taskId, long time, TimeUnit timeUnit)	Resumes the task associated with the supplied TaskId.
void	resumeWithError(TaskId taskId, Throwable throwable)	Resumes a task that was waiting for any reason.
void	setPersistence(TransactionalResourceServicePersistence persistence)
void	setResourceService(ResourceService resourceService)
void	setSimpleSchedulerContext(SimpleSchedulerContext simpleSchedulerContext)
void	start()	Starts this SchedulerContext.
void	stop()	Stops this SchedulerContext.

Methods inherited from class java.lang.Object

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

Constructor Details

TransactionalSchedulerContext

public TransactionalSchedulerContext()

Method Details

start

public void start()

Description copied from interface: SchedulerContext

Starts this SchedulerContext.

Specified by:

start in interface SchedulerContext

stop

public void stop()

Description copied from interface: SchedulerContext

Stops this SchedulerContext.

Specified by:

stop in interface SchedulerContext

resume

public void resume(TaskId taskId,
 Object... results)

Description copied from interface: SchedulerContext

Resumes the supplied task with the TaskId supplying multiple results to the destination.

Specified by:

resume in interface SchedulerContext

Parameters:

taskId - the TaskId of the supplied task

results - zero or more results from resuming the task

resumeTaskAfterDelay

public void resumeTaskAfterDelay(TaskId taskId,
 long time,
 TimeUnit timeUnit)

Description copied from interface: SchedulerContext

Resumes the task associated with the supplied TaskId. This allows for the specification of a delay after a specified period of time.

Specified by:

resumeTaskAfterDelay in interface SchedulerContext

Parameters:

taskId - the TaskId of the task

time - the time delay

timeUnit - the TimeUnit instance designating the time units of measure

resumeFromNetwork

public void resumeFromNetwork(TaskId taskId,
 Object result)

Description copied from interface: SchedulerContext

Resumes a task that was waiting on a network call.

Specified by:

resumeFromNetwork in interface SchedulerContext

Parameters:

taskId - the unique TaskId associated with the network

result - the result of the network operation, passed to the task

resumeWithError

public void resumeWithError(TaskId taskId,
 Throwable throwable)

Description copied from interface: SchedulerContext

Resumes a task that was waiting for any reason. This is used to hand an error to the running task in order to a task waiting on an operation.

Specified by:

resumeWithError in interface SchedulerContext

Parameters:

taskId - the unique TaskId associated with the network

throwable - the error in the blocked operation

getResourceService

public ResourceService getResourceService()

setResourceService

@Inject
public void setResourceService(ResourceService resourceService)

getSimpleSchedulerContext

public SimpleSchedulerContext getSimpleSchedulerContext()

setSimpleSchedulerContext

@Inject
public void setSimpleSchedulerContext(SimpleSchedulerContext simpleSchedulerContext)

getPersistence

public TransactionalResourceServicePersistence getPersistence()

setPersistence

@Inject
public void setPersistence(TransactionalResourceServicePersistence persistence)