net.esper.core
Class EPServicesContext

java.lang.Object
  extended by net.esper.core.EPServicesContext

public final class EPServicesContext
extends Object

Convenience class to hold implementations for all services.


Constructor Summary
EPServicesContext(String engineURI, String engineInstanceId, SchedulingService schedulingService, EventAdapterService eventAdapterService, EngineImportService engineImportService, DatabaseConfigService databaseConfigService, ViewResolutionService viewResolutionService, StatementLockFactory statementLockFactory, ManagedReadWriteLock eventProcessingRWLock, ExtensionServicesContext extensionServicesContext, EngineEnvContext engineEnvContext, StatementContextFactory statementContextFactory, PatternObjectResolutionService patternObjectResolutionService)
          Constructor - sets up new set of services.
 
Method Summary
 void destroy()
          Destroy services.
 DatabaseConfigService getDatabaseRefService()
          Returns the database settings service.
 DispatchService getDispatchService()
          Returns dispatch service responsible for dispatching events to listeners.
 EmitService getEmitService()
          Returns service for emitting events.
 EngineEnvContext getEngineEnvContext()
          Returns the engine environment context for getting access to engine-external resources, such as adapters
 EngineImportService getEngineImportService()
          Returns the import and class name resolution service.
 String getEngineInstanceId()
          Returns the engine instance ID.
 String getEngineURI()
          Returns the engine URI.
 EventAdapterService getEventAdapterService()
          Returns event type resolution service.
 ManagedReadWriteLock getEventProcessingRWLock()
          Returns the event processing lock for coordinating statement administration with event processing.
 ExtensionServicesContext getExtensionServicesContext()
          Returns extension service for adding custom the services.
 FilterService getFilterService()
          Returns filter evaluation service implementation.
 InternalEventRouter getInternalEventRouter()
          Returns router for internal event processing.
 PatternObjectResolutionService getPatternObjectResolutionService()
          Returns the pattern object resolver.
 SchedulingService getSchedulingService()
          Returns scheduling service implementation.
 StatementContextFactory getStatementContextFactory()
          Returns the factory to use for creating a statement context.
 StatementLifecycleSvc getStatementLifecycleSvc()
          Returns statement lifecycle svc
 StatementLockFactory getStatementLockFactory()
          Factory for statement-level locks.
 StreamFactoryService getStreamService()
          Returns stream service.
 TimerService getTimerService()
          Returns time provider service implementation.
 ViewResolutionService getViewResolutionService()
          Service for resolving view namespace and name.
 ViewService getViewService()
          Returns services for view creation, sharing and removal.
 void setInternalEventRouter(InternalEventRouter internalEventRouter)
          Set the router for internal event processing.
 void setStatementLifecycleSvc(StatementLifecycleSvc statementLifecycleSvc)
          Sets the service dealing with starting and stopping statements.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

EPServicesContext

public EPServicesContext(String engineURI,
                         String engineInstanceId,
                         SchedulingService schedulingService,
                         EventAdapterService eventAdapterService,
                         EngineImportService engineImportService,
                         DatabaseConfigService databaseConfigService,
                         ViewResolutionService viewResolutionService,
                         StatementLockFactory statementLockFactory,
                         ManagedReadWriteLock eventProcessingRWLock,
                         ExtensionServicesContext extensionServicesContext,
                         EngineEnvContext engineEnvContext,
                         StatementContextFactory statementContextFactory,
                         PatternObjectResolutionService patternObjectResolutionService)
Constructor - sets up new set of services.

Parameters:
engineURI - is the engine URI
engineInstanceId - is the name of the engine instance
schedulingService - service to get time and schedule callbacks
eventAdapterService - service to resolve event types
databaseConfigService - service to resolve a database name to database connection factory and configs
viewResolutionService - resolves view namespace and name to view factory class
statementLockFactory - creates statement-level locks
eventProcessingRWLock - is the engine lock for statement management
extensionServicesContext - marker interface allows adding additional services
engineImportService - is engine imported static func packages and aggregation functions
statementContextFactory - is the factory to use to create statement context objects
engineEnvContext - is engine environment/directory information for use with adapters and external env
patternObjectResolutionService - resolves plug-in pattern objects
Method Detail

setStatementLifecycleSvc

public void setStatementLifecycleSvc(StatementLifecycleSvc statementLifecycleSvc)
Sets the service dealing with starting and stopping statements.

Parameters:
statementLifecycleSvc - statement lifycycle svc

getInternalEventRouter

public InternalEventRouter getInternalEventRouter()
Returns router for internal event processing.

Returns:
router for internal event processing

setInternalEventRouter

public void setInternalEventRouter(InternalEventRouter internalEventRouter)
Set the router for internal event processing.

Parameters:
internalEventRouter - router to use

getFilterService

public final FilterService getFilterService()
Returns filter evaluation service implementation.

Returns:
filter evaluation service

getTimerService

public final TimerService getTimerService()
Returns time provider service implementation.

Returns:
time provider service

getSchedulingService

public final SchedulingService getSchedulingService()
Returns scheduling service implementation.

Returns:
scheduling service

getEmitService

public final EmitService getEmitService()
Returns service for emitting events.

Returns:
emit event service

getDispatchService

public DispatchService getDispatchService()
Returns dispatch service responsible for dispatching events to listeners.

Returns:
dispatch service.

getViewService

public ViewService getViewService()
Returns services for view creation, sharing and removal.

Returns:
view service

getStreamService

public StreamFactoryService getStreamService()
Returns stream service.

Returns:
stream service

getEventAdapterService

public EventAdapterService getEventAdapterService()
Returns event type resolution service.

Returns:
service resolving event type

getEngineImportService

public EngineImportService getEngineImportService()
Returns the import and class name resolution service.

Returns:
import service

getDatabaseRefService

public DatabaseConfigService getDatabaseRefService()
Returns the database settings service.

Returns:
database info service

getViewResolutionService

public ViewResolutionService getViewResolutionService()
Service for resolving view namespace and name.

Returns:
view resolution svc

getStatementLockFactory

public StatementLockFactory getStatementLockFactory()
Factory for statement-level locks.

Returns:
factory

getEventProcessingRWLock

public ManagedReadWriteLock getEventProcessingRWLock()
Returns the event processing lock for coordinating statement administration with event processing.

Returns:
lock

getStatementLifecycleSvc

public StatementLifecycleSvc getStatementLifecycleSvc()
Returns statement lifecycle svc

Returns:
service for statement start and stop

getExtensionServicesContext

public ExtensionServicesContext getExtensionServicesContext()
Returns extension service for adding custom the services.

Returns:
extension service context

getEngineEnvContext

public EngineEnvContext getEngineEnvContext()
Returns the engine environment context for getting access to engine-external resources, such as adapters

Returns:
engine environment context

destroy

public void destroy()
Destroy services.


getStatementContextFactory

public StatementContextFactory getStatementContextFactory()
Returns the factory to use for creating a statement context.

Returns:
statement context factory

getEngineURI

public String getEngineURI()
Returns the engine URI.

Returns:
engine URI

getEngineInstanceId

public String getEngineInstanceId()
Returns the engine instance ID.

Returns:
instance id

getPatternObjectResolutionService

public PatternObjectResolutionService getPatternObjectResolutionService()
Returns the pattern object resolver.

Returns:
resolver for plug-in pattern objects.