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, SchedulingService schedulingService, EventAdapterService eventAdapterService, EngineImportService engineImportService, EngineSettingsService engineSettingsService, DatabaseConfigService databaseConfigService, PluggableObjectCollection plugInViews, StatementLockFactory statementLockFactory, ManagedReadWriteLock eventProcessingRWLock, ExtensionServicesContext extensionServicesContext, EngineEnvContext engineEnvContext, StatementContextFactory statementContextFactory, PluggableObjectCollection plugInPatternObjects, OutputConditionFactory outputConditionFactory, TimerService timerService, boolean isShareViews)
          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.
 EngineSettingsService getEngineSettingsService()
          Returns engine settings.
 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.
 OutputConditionFactory getOutputConditionFactory()
          Returns the output condition factory
 PluggableObjectCollection getPlugInPatternObjects()
          Information to resolve plug-in pattern object namespace and name.
 PluggableObjectCollection getPlugInViews()
          Information to resolve plug-in view namespace and name.
 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.
 ViewService getViewService()
          Returns services for view creation, sharing and removal.
 void initialize()
          Destroy services.
 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,
                         SchedulingService schedulingService,
                         EventAdapterService eventAdapterService,
                         EngineImportService engineImportService,
                         EngineSettingsService engineSettingsService,
                         DatabaseConfigService databaseConfigService,
                         PluggableObjectCollection plugInViews,
                         StatementLockFactory statementLockFactory,
                         ManagedReadWriteLock eventProcessingRWLock,
                         ExtensionServicesContext extensionServicesContext,
                         EngineEnvContext engineEnvContext,
                         StatementContextFactory statementContextFactory,
                         PluggableObjectCollection plugInPatternObjects,
                         OutputConditionFactory outputConditionFactory,
                         TimerService timerService,
                         boolean isShareViews)
Constructor - sets up new set of services.

Parameters:
engineURI - is the engine URI
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
plugInViews - 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
engineSettingsService - provides engine settings
statementContextFactory - is the factory to use to create statement context objects
engineEnvContext - is engine environment/directory information for use with adapters and external env
plugInPatternObjects - resolves plug-in pattern objects
outputConditionFactory - factory for output condition objects
timerService - is the timer service
isShareViews - is a boolean indicating whether the engine shares view resources between statements
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

getPlugInViews

public PluggableObjectCollection getPlugInViews()
Information to resolve plug-in view namespace and name.

Returns:
plug-in view information

getPlugInPatternObjects

public PluggableObjectCollection getPlugInPatternObjects()
Information to resolve plug-in pattern object namespace and name.

Returns:
plug-in pattern object information

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.


initialize

public void initialize()
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

getEngineSettingsService

public EngineSettingsService getEngineSettingsService()
Returns engine settings.

Returns:
settings

getOutputConditionFactory

public OutputConditionFactory getOutputConditionFactory()
Returns the output condition factory

Returns:
factory for output condition