Package | Description |
---|---|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.dispatch |
Dispatching makes results available to joins and handles internal event routing
|
Modifier and Type | Field and Description |
---|---|
protected DispatchService |
UpdateDispatchViewBase.dispatchService
Dispatches events to listeners.
|
Modifier and Type | Method and Description |
---|---|
DispatchService |
EPServicesContext.getDispatchService()
Returns dispatch service responsible for dispatching events to listeners.
|
Modifier and Type | Method and Description |
---|---|
EPStatementSPI |
EPStatementFactoryDefault.make(String expressionNoAnnotations,
boolean isPattern,
DispatchService dispatchService,
StatementLifecycleSvcImpl statementLifecycleSvc,
long timeLastStateChange,
boolean preserveDispatchOrder,
boolean isSpinLocks,
long blockingTimeout,
TimeSourceService timeSource,
StatementMetadata statementMetadata,
Object statementUserObject,
StatementContext statementContext,
boolean isFailed,
boolean nameProvided) |
EPStatementSPI |
EPStatementFactory.make(String expressionNoAnnotations,
boolean isPattern,
DispatchService dispatchService,
StatementLifecycleSvcImpl statementLifecycleSvc,
long timeLastStateChange,
boolean preserveDispatchOrder,
boolean isSpinLocks,
long blockingTimeout,
TimeSourceService timeSource,
StatementMetadata statementMetadata,
Object statementUserObject,
StatementContext statementContext,
boolean isFailed,
boolean nameProvided) |
Constructor and Description |
---|
EPStatementImpl(String expressionNoAnnotations,
boolean isPattern,
DispatchService dispatchService,
StatementLifecycleSvc statementLifecycleSvc,
long timeLastStateChange,
boolean isBlockingDispatch,
boolean isSpinBlockingDispatch,
long msecBlockingTimeout,
TimeSourceService timeSourceService,
StatementMetadata statementMetadata,
Object userObject,
StatementContext statementContext,
boolean isFailed,
boolean nameProvided)
Ctor.
|
UpdateDispatchViewBase(StatementResultService statementResultServiceImpl,
DispatchService dispatchService)
Ctor.
|
UpdateDispatchViewBlockingSpin(StatementResultService statementResultService,
DispatchService dispatchService,
long msecTimeout,
TimeSourceService timeSourceService)
Ctor.
|
UpdateDispatchViewBlockingWait(StatementResultService statementResultServiceImpl,
DispatchService dispatchService,
long msecTimeout)
Ctor.
|
UpdateDispatchViewNonBlocking(StatementResultService statementResultServiceImpl,
DispatchService dispatchService)
Ctor.
|
Modifier and Type | Class and Description |
---|---|
class |
DispatchServiceImpl
Implements dispatch service using a thread-local linked list of Dispatchable instances.
|
Modifier and Type | Method and Description |
---|---|
static DispatchService |
DispatchServiceProvider.newService()
Returns new service.
|