com.espertech.esper.core.service

Class EPServicesContextFactoryDefault

java.lang.Object

com.espertech.esper.core.service.EPServicesContextFactoryDefault

All Implemented Interfaces:

EPServicesContextFactory

public class EPServicesContextFactoryDefault
extends java.lang.Object
implements EPServicesContextFactory

Factory for services context.

Constructor Summary

Constructors

Constructor and Description
EPServicesContextFactoryDefault()

Method Summary

Modifier and Type	Method and Description
EPServicesContext	createServicesContext(EPServiceProvider epServiceProvider, ConfigurationInformation configSnapshot) Factory method for a new set of engine services.
protected static void	init(EventAdapterService eventAdapterService, ConfigurationInformation configSnapshot, EngineImportService engineImportService) Initialize event adapter service for config snapshot.
protected static ExceptionHandlingService	initExceptionHandling(java.lang.String engineURI, ConfigurationEngineDefaults.ExceptionHandling exceptionHandling, ConfigurationEngineDefaults.ConditionHandling conditionHandling, EngineImportService engineImportService)
protected static void	initVariables(VariableService variableService, java.util.Map<java.lang.String,ConfigurationVariable> variables, EngineImportService engineImportService) Adds configured variables to the variable service.
protected static DatabaseConfigService	makeDatabaseRefService(ConfigurationInformation configSnapshot, SchedulingService schedulingService, SchedulingMgmtService schedulingMgmtService, EngineImportService engineImportService) Creates the database config service.
protected static EngineImportService	makeEngineImportService(ConfigurationInformation configSnapshot, AggregationFactoryFactory aggregationFactoryFactory, java.lang.String engineURI) Constructs the auto import service.
protected static TimeSourceService	makeTimeSource(ConfigurationInformation configSnapshot) Makes the time source provider.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EPServicesContextFactoryDefault

public EPServicesContextFactoryDefault()

Method Detail

createServicesContext

public EPServicesContext createServicesContext(EPServiceProvider epServiceProvider,
                                               ConfigurationInformation configSnapshot)

Description copied from interface: EPServicesContextFactory

Factory method for a new set of engine services.

Specified by:

createServicesContext in interface EPServicesContextFactory

Parameters:

epServiceProvider - is the engine instance

configSnapshot - is a snapshot of configs at the time of engine creation

Returns:

services context

initExceptionHandling

protected static ExceptionHandlingService initExceptionHandling(java.lang.String engineURI,
                                                                ConfigurationEngineDefaults.ExceptionHandling exceptionHandling,
                                                                ConfigurationEngineDefaults.ConditionHandling conditionHandling,
                                                                EngineImportService engineImportService)
                                                         throws ConfigurationException

Throws:

ConfigurationException

makeTimeSource

protected static TimeSourceService makeTimeSource(ConfigurationInformation configSnapshot)

Makes the time source provider.

Parameters:

configSnapshot - the configuration

Returns:

time source provider

initVariables

protected static void initVariables(VariableService variableService,
                                    java.util.Map<java.lang.String,ConfigurationVariable> variables,
                                    EngineImportService engineImportService)

Adds configured variables to the variable service.

Parameters:

variableService - service to add to

variables - configured variables

engineImportService - engine imports

init

protected static void init(EventAdapterService eventAdapterService,
                           ConfigurationInformation configSnapshot,
                           EngineImportService engineImportService)

Initialize event adapter service for config snapshot.

Parameters:

eventAdapterService - is events adapter

configSnapshot - is the config snapshot

engineImportService - engine import service

makeEngineImportService

protected static EngineImportService makeEngineImportService(ConfigurationInformation configSnapshot,
                                                             AggregationFactoryFactory aggregationFactoryFactory,
                                                             java.lang.String engineURI)

Constructs the auto import service.

Parameters:

configSnapshot - config info

aggregationFactoryFactory - factory of aggregation service provider

engineURI - engine URI

Returns:

service

makeDatabaseRefService

protected static DatabaseConfigService makeDatabaseRefService(ConfigurationInformation configSnapshot,
                                                              SchedulingService schedulingService,
                                                              SchedulingMgmtService schedulingMgmtService,
                                                              EngineImportService engineImportService)

Creates the database config service.

Parameters:

configSnapshot - is the config snapshot

schedulingService - is the timer stuff

schedulingMgmtService - for statement schedule management

engineImportService - engine import service

Returns:

database config svc