com.espertech.esperio
Interface CoordinatedAdapter

All Superinterfaces:

com.espertech.esper.adapter.Adapter, com.espertech.esper.adapter.InputAdapter

All Known Implementing Classes:

AbstractCoordinatedAdapter, AdapterCoordinatorImpl, CSVInputAdapter

public interface CoordinatedAdapter
extends com.espertech.esper.adapter.InputAdapter

An Adapter that can be coordinated by an AdapterCoordinator.

Field Summary

Fields inherited from interface com.espertech.esper.adapter.InputAdapter

ESPERIO_MAP_EVENT_TYPE

Method Summary

void	disallowStateTransitions() Disallow subsequent state changes and throw an IllegalStateTransitionException if they are attempted.
SendableEvent	read() Get the next event in line to be sent into the runtime , or null if there is no available event.
void	setEPService(com.espertech.esper.client.EPServiceProvider epService) Set the epService
void	setScheduleSlot(com.espertech.esper.schedule.ScheduleSlot scheduleSlot) Set the scheduleSlot for this Adapter.
void	setUsingEngineThread(boolean usingEngineThread) Set the usingEngineThread value
void	setUsingExternalTimer(boolean usingExternalTimer) Set the usingExternalTimer value

Methods inherited from interface com.espertech.esper.adapter.Adapter

destroy, getState, pause, resume, start, stop

Method Detail

read

SendableEvent read()
                   throws com.espertech.esper.client.EPException

Get the next event in line to be sent into the runtime , or null if there is no available event.

Returns:

an instance of SendableEvent that wraps the next event to send, or null if none

Throws:

com.espertech.esper.client.EPException - in case of errors creating the event

setUsingEngineThread

void setUsingEngineThread(boolean usingEngineThread)

Set the usingEngineThread value

Parameters:

usingEngineThread - - the value to set

setUsingExternalTimer

void setUsingExternalTimer(boolean usingExternalTimer)

Set the usingExternalTimer value

Parameters:

usingExternalTimer - - the value to set

disallowStateTransitions

void disallowStateTransitions()

Disallow subsequent state changes and throw an IllegalStateTransitionException if they are attempted.

setScheduleSlot

void setScheduleSlot(com.espertech.esper.schedule.ScheduleSlot scheduleSlot)

Set the scheduleSlot for this Adapter.

Parameters:

scheduleSlot - - the scheduleSlot to set

setEPService

void setEPService(com.espertech.esper.client.EPServiceProvider epService)

Set the epService

Parameters:

epService - - the value to set