net.esper.core
Class EPServicesContext

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

public final class EPServicesContext
extends Object

Convenience class to instantiate implementations for all services.


Constructor Summary
EPServicesContext(SchedulingService schedulingService, EventAdapterService eventAdapterService, AutoImportService autoImportService, DatabaseConfigService databaseConfigService, ViewResolutionService viewResolutionService, StatementLockFactory statementLockFactory, ManagedReadWriteLock eventProcessingRWLock, ExtensionServicesContext extensionServicesContext, EngineEnvContext engineEnvContext)
          Constructor - sets up new set of services.
 
Method Summary
 void destroy()
          Destroy services.
 AutoImportService getAutoImportService()
          Returns the import and class name resolution service.
 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()
           
 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.
 SchedulingService getSchedulingService()
          Returns scheduling service implementation.
 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(SchedulingService schedulingService,
                         EventAdapterService eventAdapterService,
                         AutoImportService autoImportService,
                         DatabaseConfigService databaseConfigService,
                         ViewResolutionService viewResolutionService,
                         StatementLockFactory statementLockFactory,
                         ManagedReadWriteLock eventProcessingRWLock,
                         ExtensionServicesContext extensionServicesContext,
                         EngineEnvContext engineEnvContext)
Constructor - sets up new set of services.

Parameters:
schedulingService - service to get time and schedule callbacks
eventAdapterService - service to resolve event types
autoImportService - service to resolve partial class names
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
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

getAutoImportService

public AutoImportService getAutoImportService()
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()

destroy

public void destroy()
Destroy services.