com.espertech.esper.core.service
Class EPServicesContext

java.lang.Object
  com.espertech.esper.core.service.EPServicesContext

public final class EPServicesContext
extends java.lang.Object

Convenience class to hold implementations for all services.

Constructor Summary

EPServicesContext(java.lang.String engineURI, SchedulingServiceSPI schedulingService, EventAdapterService eventAdapterService, EngineImportService engineImportService, EngineSettingsService engineSettingsService, DatabaseConfigService databaseConfigService, PluggableObjectCollection plugInViews, StatementLockFactory statementLockFactory, ManagedReadWriteLock eventProcessingRWLock, ExtensionServicesContext extensionServicesContext, EngineEnvContext engineEnvContext, StatementContextFactory statementContextFactory, PluggableObjectCollection plugInPatternObjects, TimerService timerService, FilterServiceSPI filterService, StreamFactoryService streamFactoryService, NamedWindowService namedWindowService, VariableService variableService, TableService tableService, TimeSourceService timeSourceService, ValueAddEventService valueAddEventService, MetricReportingServiceSPI metricsReportingService, StatementEventTypeRef statementEventTypeRef, StatementVariableRef statementVariableRef, ConfigurationInformation configSnapshot, ThreadingService threadingServiceImpl, InternalEventRouterImpl internalEventRouter, StatementIsolationService statementIsolationService, SchedulingMgmtService schedulingMgmtService, DeploymentStateService deploymentStateService, ExceptionHandlingService exceptionHandlingService, PatternNodeFactory patternNodeFactory, EventTypeIdGenerator eventTypeIdGenerator, StatementMetadataFactory statementMetadataFactory, ContextManagementService contextManagementService, SchedulableAgentInstanceDirectory schedulableAgentInstanceDirectory, PatternSubexpressionPoolEngineSvc patternSubexpressionPoolSvc, DataFlowService dataFlowService, ExprDeclaredService exprDeclaredService)
Constructor - sets up new set of services.

Method Summary

void	destroy() Destroy services.
ConfigurationInformation	getConfigSnapshot() Returns the configuration.
ContextManagementService	getContextManagementService()
DatabaseConfigService	getDatabaseRefService() Returns the database settings service.
DataFlowService	getDataFlowService()
DeploymentStateService	getDeploymentStateService()
DispatchService	getDispatchService() Returns dispatch service responsible for dispatching events to listeners.
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.
EngineSettingsService	getEngineSettingsService() Returns engine settings.
java.lang.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.
EventTypeIdGenerator	getEventTypeIdGenerator()
ExceptionHandlingService	getExceptionHandlingService()
ExprDeclaredService	getExprDeclaredService()
ExpressionResultCacheService	getExpressionResultCacheSharable()
ExtensionServicesContext	getExtensionServicesContext() Returns extension service for adding custom the services.
FilterServiceSPI	getFilterService() Returns filter evaluation service implementation.
InternalEventRouteDest	getInternalEventEngineRouteDest() Returns the event routing destination.
InternalEventRouterImpl	getInternalEventRouter() Returns router for internal event processing.
MetricReportingServiceSPI	getMetricsReportingService() Returns metrics reporting.
NamedWindowService	getNamedWindowService() Returns the named window management service.
PatternNodeFactory	getPatternNodeFactory()
PatternSubexpressionPoolEngineSvc	getPatternSubexpressionPoolSvc()
PluggableObjectCollection	getPlugInPatternObjects() Information to resolve plug-in pattern object namespace and name.
PluggableObjectCollection	getPlugInViews() Information to resolve plug-in view namespace and name.
SchedulableAgentInstanceDirectory	getSchedulableAgentInstanceDirectory()
SchedulingMgmtService	getSchedulingMgmtService() Returns the schedule management service.
SchedulingServiceSPI	getSchedulingService() Returns scheduling service implementation.
StatementContextFactory	getStatementContextFactory() } public ExpressionResultCacheService getExpressionResultCacheSharable() { return expressionResultCacheSharable; Returns the factory to use for creating a statement context.
StatementEventTypeRef	getStatementEventTypeRefService() Returns service for statement to event type mapping.
StatementIsolationService	getStatementIsolationService() Returns the service for maintaining statement isolation information.
StatementLifecycleSvc	getStatementLifecycleSvc() Returns statement lifecycle svc
StatementLockFactory	getStatementLockFactory() Factory for statement-level locks.
StatementMetadataFactory	getStatementMetadataFactory()
StatementVariableRef	getStatementVariableRefService() Service for keeping track of variable-statement use.
StreamFactoryService	getStreamService() Returns stream service.
TableService	getTableService()
ThreadingService	getThreadingService() Returns engine-level threading settings.
TimerService	getTimerService() Returns time provider service implementation.
TimeSourceService	getTimeSource() Returns the time source provider class.
ValueAddEventService	getValueAddEventService() Returns the service for handling updates to events.
VariableService	getVariableService() Returns the variable service.
ViewService	getViewService() Returns services for view creation, sharing and removal.
void	initialize() Destroy services.
void	setInternalEventEngineRouteDest(InternalEventRouteDest internalEventEngineRouteDest) Sets the event routing destination.
void	setStatementIsolationService(StatementIsolationService statementIsolationService) Sets the service for maintaining statement isolation information.
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(java.lang.String engineURI,
                         SchedulingServiceSPI schedulingService,
                         EventAdapterService eventAdapterService,
                         EngineImportService engineImportService,
                         EngineSettingsService engineSettingsService,
                         DatabaseConfigService databaseConfigService,
                         PluggableObjectCollection plugInViews,
                         StatementLockFactory statementLockFactory,
                         ManagedReadWriteLock eventProcessingRWLock,
                         ExtensionServicesContext extensionServicesContext,
                         EngineEnvContext engineEnvContext,
                         StatementContextFactory statementContextFactory,
                         PluggableObjectCollection plugInPatternObjects,
                         TimerService timerService,
                         FilterServiceSPI filterService,
                         StreamFactoryService streamFactoryService,
                         NamedWindowService namedWindowService,
                         VariableService variableService,
                         TableService tableService,
                         TimeSourceService timeSourceService,
                         ValueAddEventService valueAddEventService,
                         MetricReportingServiceSPI metricsReportingService,
                         StatementEventTypeRef statementEventTypeRef,
                         StatementVariableRef statementVariableRef,
                         ConfigurationInformation configSnapshot,
                         ThreadingService threadingServiceImpl,
                         InternalEventRouterImpl internalEventRouter,
                         StatementIsolationService statementIsolationService,
                         SchedulingMgmtService schedulingMgmtService,
                         DeploymentStateService deploymentStateService,
                         ExceptionHandlingService exceptionHandlingService,
                         PatternNodeFactory patternNodeFactory,
                         EventTypeIdGenerator eventTypeIdGenerator,
                         StatementMetadataFactory statementMetadataFactory,
                         ContextManagementService contextManagementService,
                         SchedulableAgentInstanceDirectory schedulableAgentInstanceDirectory,
                         PatternSubexpressionPoolEngineSvc patternSubexpressionPoolSvc,
                         DataFlowService dataFlowService,
                         ExprDeclaredService exprDeclaredService)

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

timerService - is the timer service

filterService - the filter service

streamFactoryService - is hooking up filters to streams

namedWindowService - is holding information about the named windows active in the system

variableService - provides access to variable values

valueAddEventService - handles update events

timeSourceService - time source provider class

metricsReportingService - - for metric reporting

statementEventTypeRef - - statement to event type reference holding

statementVariableRef - - statement to variabke reference holding

configSnapshot - configuration snapshot

threadingServiceImpl - - engine-level threading services

internalEventRouter - - routing of events

statementIsolationService - - maintains isolation information per statement

schedulingMgmtService - - schedule management for statements

Method Detail

getPatternNodeFactory

public PatternNodeFactory getPatternNodeFactory()

setStatementLifecycleSvc

public void setStatementLifecycleSvc(StatementLifecycleSvc statementLifecycleSvc)

Sets the service dealing with starting and stopping statements.

Parameters:

statementLifecycleSvc - statement lifycycle svc

getInternalEventEngineRouteDest

public InternalEventRouteDest getInternalEventEngineRouteDest()

Returns the event routing destination.

Returns:

event routing destination

setInternalEventEngineRouteDest

public void setInternalEventEngineRouteDest(InternalEventRouteDest internalEventEngineRouteDest)

Sets the event routing destination.

Parameters:

internalEventEngineRouteDest - event routing destination

getInternalEventRouter

public InternalEventRouterImpl getInternalEventRouter()

Returns router for internal event processing.

Returns:

router for internal event processing

getFilterService

public final FilterServiceSPI 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 SchedulingServiceSPI getSchedulingService()

Returns scheduling service implementation.

Returns:

scheduling 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

getThreadingService

public ThreadingService getThreadingService()

Returns engine-level threading settings.

Returns:

threading service

destroy

public void destroy()

Destroy services.

initialize

public void initialize()

Destroy services.

getStatementContextFactory

public StatementContextFactory getStatementContextFactory()

} public ExpressionResultCacheService getExpressionResultCacheSharable() { return expressionResultCacheSharable; Returns the factory to use for creating a statement context.

Returns:

statement context factory

getEngineURI

public java.lang.String getEngineURI()

Returns the engine URI.

Returns:

engine URI

getEngineSettingsService

public EngineSettingsService getEngineSettingsService()

Returns engine settings.

Returns:

settings

getNamedWindowService

public NamedWindowService getNamedWindowService()

Returns the named window management service.

Returns:

service for managing named windows

getVariableService

public VariableService getVariableService()

Returns the variable service.

Returns:

variable service

getTimeSource

public TimeSourceService getTimeSource()

Returns the time source provider class.

Returns:

time source

getValueAddEventService

public ValueAddEventService getValueAddEventService()

Returns the service for handling updates to events.

Returns:

revision service

getMetricsReportingService

public MetricReportingServiceSPI getMetricsReportingService()

Returns metrics reporting.

Returns:

metrics reporting

getStatementEventTypeRefService

public StatementEventTypeRef getStatementEventTypeRefService()

Returns service for statement to event type mapping.

Returns:

statement-type mapping

getConfigSnapshot

public ConfigurationInformation getConfigSnapshot()

Returns the configuration.

Returns:

configuration

getStatementVariableRefService

public StatementVariableRef getStatementVariableRefService()

Service for keeping track of variable-statement use.

Returns:

svc

getSchedulingMgmtService

public SchedulingMgmtService getSchedulingMgmtService()

Returns the schedule management service.

Returns:

schedule management service

getStatementIsolationService

public StatementIsolationService getStatementIsolationService()

Returns the service for maintaining statement isolation information.

Returns:

isolation service

setStatementIsolationService

public void setStatementIsolationService(StatementIsolationService statementIsolationService)

Sets the service for maintaining statement isolation information.

Parameters:

statementIsolationService - isolation service

getDeploymentStateService

public DeploymentStateService getDeploymentStateService()

getExceptionHandlingService

public ExceptionHandlingService getExceptionHandlingService()

getEventTypeIdGenerator

public EventTypeIdGenerator getEventTypeIdGenerator()

getStatementMetadataFactory

public StatementMetadataFactory getStatementMetadataFactory()

getContextManagementService

public ContextManagementService getContextManagementService()

getSchedulableAgentInstanceDirectory

public SchedulableAgentInstanceDirectory getSchedulableAgentInstanceDirectory()

getPatternSubexpressionPoolSvc

public PatternSubexpressionPoolEngineSvc getPatternSubexpressionPoolSvc()

getDataFlowService

public DataFlowService getDataFlowService()

getExprDeclaredService

public ExprDeclaredService getExprDeclaredService()

getExpressionResultCacheSharable

public ExpressionResultCacheService getExpressionResultCacheSharable()

getTableService

public TableService getTableService()