net.esper.adapter
Class AdapterCoordinatorImpl

java.lang.Object
  net.esper.adapter.AbstractCoordinatedAdapter
      net.esper.adapter.AdapterCoordinatorImpl

All Implemented Interfaces:

Adapter, AdapterCoordinator, CoordinatedAdapter, InputAdapter

public class AdapterCoordinatorImpl
extends AbstractCoordinatedAdapter
implements AdapterCoordinator

An implementation of AdapterCoordinator.

Field Summary

Fields inherited from class net.esper.adapter.AbstractCoordinatedAdapter

eventsToSend, scheduleSlot, stateManager

Fields inherited from interface net.esper.adapter.InputAdapter

ESPERIO_MAP_EVENT_TYPE

Constructor Summary

AdapterCoordinatorImpl(net.esper.client.EPServiceProvider epService, boolean usingEngineThread)
Ctor.

Method Summary

protected void	close() Does nothing.
void	coordinate(InputAdapter inputAdapter) Coordinate an InputAdapter.
SendableEvent	read() Get the next event in line to be sent into the runtime , or null if there is no available event.
protected void	replaceFirstEventToSend() Replace the first member of eventsToSend with the next event returned by the read() method of the same Adapter that provided the first event.
protected void	reset() Reset all the changeable state of this ReadableAdapter, as if it were just created.

Methods inherited from class net.esper.adapter.AbstractCoordinatedAdapter

destroy, disallowStateTransitions, getState, pause, resume, setEPService, setScheduleSlot, setUsingEngineThread, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.esper.adapter.Adapter

destroy, getState, pause, resume, start, stop

Constructor Detail

AdapterCoordinatorImpl

public AdapterCoordinatorImpl(net.esper.client.EPServiceProvider epService,
                              boolean usingEngineThread)

Ctor.

Parameters:

epService - - the EPServiceProvider for the engine services and runtime

usingEngineThread - - true if the coordinator should set time by the scheduling service in the engine, false if it should set time externally through the calling thread

Method Detail

read

public SendableEvent read()
                   throws net.esper.client.EPException

Description copied from interface: CoordinatedAdapter

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

Specified by:

read in interface CoordinatedAdapter

Returns:

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

Throws:

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

coordinate

public void coordinate(InputAdapter inputAdapter)

Description copied from interface: AdapterCoordinator

Coordinate an InputAdapter.

Specified by:

coordinate in interface AdapterCoordinator

Parameters:

inputAdapter - - the InputAdapter to coordinate

close

protected void close()

Does nothing.

Specified by:

close in class AbstractCoordinatedAdapter

replaceFirstEventToSend

protected void replaceFirstEventToSend()

Replace the first member of eventsToSend with the next event returned by the read() method of the same Adapter that provided the first event.

Specified by:

replaceFirstEventToSend in class AbstractCoordinatedAdapter

reset

protected void reset()

Reset all the changeable state of this ReadableAdapter, as if it were just created.

Specified by:

reset in class AbstractCoordinatedAdapter