|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.esper.core.EPRuntimeImpl
public class EPRuntimeImpl
Implements runtime interface. Also accepts timer callbacks for synchronizing time events with regular events sent in.
Constructor Summary | |
---|---|
EPRuntimeImpl(EPServicesContext services)
Constructor. |
Method Summary | |
---|---|
void |
addEmittedListener(EmittedListener listener,
java.lang.String channel)
Register an object that listens for events emitted from the event stream processing runtime on the specified channel. |
void |
clearEmittedListeners()
Deregister all emitted event listeners. |
void |
emit(java.lang.Object object)
Emit an event object to any registered EmittedListener instances listening to the default channel. |
void |
emit(java.lang.Object object,
java.lang.String channel)
Emit an event object to any registered EmittedListener instances on the specified channel. |
int |
getNumEventsEmitted()
Number of events emitted over the lifetime of the event stream processing runtime. |
int |
getNumEventsReceived()
Number of events received over the lifetime of the event stream processing runtime. |
void |
route(java.lang.Object event)
Route the event object back to the event stream processing runtime for internal dispatching. |
void |
sendEvent(java.lang.Object event)
Send an event to the event stream processing runtime. |
void |
timerCallback()
Invoked by the internal clocking service at regular intervals. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public EPRuntimeImpl(EPServicesContext services)
services
- - references to servicesMethod Detail |
---|
public void sendEvent(java.lang.Object event) throws EPException
EPRuntime
sendEvent
in interface EPRuntime
event
- is the event to sent to the runtime
EPException
- is thrown when the processing of the event lead to an errorpublic int getNumEventsReceived()
EPRuntime
getNumEventsReceived
in interface EPRuntime
public int getNumEventsEmitted()
EPRuntime
getNumEventsEmitted
in interface EPRuntime
public void route(java.lang.Object event)
EPRuntime
route
in interface EPRuntime
event
- to route internally for processing by the event stream processing runtimepublic void emit(java.lang.Object object)
EPRuntime
emit
in interface EPRuntime
object
- to be emitted to the default channelpublic void emit(java.lang.Object object, java.lang.String channel)
EPRuntime
emit
in interface EPRuntime
object
- to be emittedchannel
- channel to emit the object to, or null if emitting to the default channelpublic void addEmittedListener(EmittedListener listener, java.lang.String channel)
EPRuntime
addEmittedListener
in interface EPRuntime
listener
- called when an event is emitted by the runtime.channel
- is the channel to add the listener to, a null value can be used to listen to events emitted
on all channelspublic void clearEmittedListeners()
EPRuntime
clearEmittedListeners
in interface EPRuntime
public void timerCallback()
TimerCallback
timerCallback
in interface TimerCallback
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |