com.espertech.esper.core.service

Class SchedulingServiceAudit

java.lang.Object

com.espertech.esper.core.service.SchedulingServiceAudit

All Implemented Interfaces:

SchedulingService, SchedulingServiceSPI, TimeProvider

public class SchedulingServiceAudit
extends Object
implements SchedulingServiceSPI

Constructor Summary

Constructors

Constructor and Description
SchedulingServiceAudit(String engineUri, String statementName, SchedulingServiceSPI spi)

Method Summary

Modifier and Type	Method and Description
void	add(long afterMSec, ScheduleHandle handle, long slot) Add a callback for after the given milliseconds from the current time.
void	apply(ScheduleSet scheduleSet) Apply the set of schedules.
void	destroy() Destroy the service.
void	evaluate(Collection<ScheduleHandle> handles) Evaluate the current time and add to the collection any handles scheduled for execution.
Long	getFurthestTimeHandle() Returns furthest in the future handle.
Long	getNearestTimeHandle()
int	getScheduleHandleCount() Returns count of handles.
long	getTime() Returns the current engine time.
int	getTimeHandleCount() Returns time handle count.
void	init() Initialization is optional and provides a chance to preload things after statements are available.
boolean	isScheduled(ScheduleHandle handle) Returns true if the handle has been scheduled already.
void	remove(ScheduleHandle handle, long slot) Remove a handle.
void	setTime(long timestamp) Set the time based upon which the evaluation of events invokes callbacks.
ScheduleSet	take(Set<Integer> statementId) Take a statement's schedules out of the currently active set of schedules.
void	visitSchedules(ScheduleVisitor visitor)

Methods inherited from class java.lang.Object

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

Constructor Detail

SchedulingServiceAudit

public SchedulingServiceAudit(String engineUri,
                              String statementName,
                              SchedulingServiceSPI spi)

Method Detail

isScheduled

public boolean isScheduled(ScheduleHandle handle)

Description copied from interface: SchedulingService

Returns true if the handle has been scheduled already.

Specified by:

isScheduled in interface SchedulingService

Parameters:

handle - to check

Returns:

indicator whether the handle is in use

take

public ScheduleSet take(Set<Integer> statementId)

Description copied from interface: SchedulingServiceSPI

Take a statement's schedules out of the currently active set of schedules.

Specified by:

take in interface SchedulingServiceSPI

Parameters:

statementId - statements to take out

Returns:

schedules

apply

public void apply(ScheduleSet scheduleSet)

Description copied from interface: SchedulingServiceSPI

Apply the set of schedules.

Specified by:

apply in interface SchedulingServiceSPI

Parameters:

scheduleSet - to apply

getNearestTimeHandle

public Long getNearestTimeHandle()

Specified by:

getNearestTimeHandle in interface SchedulingServiceSPI

visitSchedules

public void visitSchedules(ScheduleVisitor visitor)

Specified by:

visitSchedules in interface SchedulingServiceSPI

add

public void add(long afterMSec,
                ScheduleHandle handle,
                long slot)
         throws ScheduleServiceException

Description copied from interface: SchedulingService

Add a callback for after the given milliseconds from the current time. If the same callback (equals) was already added before, the method will not add a new callback or change the existing callback to a new time, but throw an exception.

Specified by:

add in interface SchedulingService

Parameters:

afterMSec - number of millisec to get a callback

handle - to add

slot - allows ordering of concurrent callbacks

Throws:

ScheduleServiceException - thrown if the add operation did not complete

remove

public void remove(ScheduleHandle handle,
                   long slot)
            throws ScheduleServiceException

Description copied from interface: SchedulingService

Remove a handle. If the handle to be removed was not found an exception is thrown.

Specified by:

remove in interface SchedulingService

Parameters:

handle - to remove

slot - for which the callback was added

Throws:

ScheduleServiceException - thrown if the callback was not located

setTime

public void setTime(long timestamp)

Description copied from interface: SchedulingService

Set the time based upon which the evaluation of events invokes callbacks.

Specified by:

setTime in interface SchedulingService

Parameters:

timestamp - to set

evaluate

public void evaluate(Collection<ScheduleHandle> handles)

Description copied from interface: SchedulingService

Evaluate the current time and add to the collection any handles scheduled for execution.

Specified by:

evaluate in interface SchedulingService

Parameters:

handles - is a collection of handles populated by the service with any callbacks due for the current time

destroy

public void destroy()

Description copied from interface: SchedulingService

Destroy the service.

Specified by:

destroy in interface SchedulingService

getTimeHandleCount

public int getTimeHandleCount()

Description copied from interface: SchedulingService

Returns time handle count.

Specified by:

getTimeHandleCount in interface SchedulingService

Returns:

count

getFurthestTimeHandle

public Long getFurthestTimeHandle()

Description copied from interface: SchedulingService

Returns furthest in the future handle.

Specified by:

getFurthestTimeHandle in interface SchedulingService

Returns:

future handle

getScheduleHandleCount

public int getScheduleHandleCount()

Description copied from interface: SchedulingService

Returns count of handles.

Specified by:

getScheduleHandleCount in interface SchedulingService

Returns:

count

getTime

public long getTime()

Description copied from interface: TimeProvider

Returns the current engine time.

Specified by:

getTime in interface TimeProvider

Returns:

time that has last been set

init

public void init()

Description copied from interface: SchedulingServiceSPI

Initialization is optional and provides a chance to preload things after statements are available.

Specified by:

init in interface SchedulingServiceSPI