com.espertech.esper.runtime.internal.kernel.service

Class EPRuntimeImpl

java.lang.Object

com.espertech.esper.runtime.internal.kernel.service.EPRuntimeImpl

All Implemented Interfaces:

EPRuntime, EPRuntimeSPI

public class EPRuntimeImpl
extends Object
implements EPRuntimeSPI

Service provider encapsulates the runtime's services for runtime and administration interfaces.

Constructor Summary

Constructors

Constructor and Description
EPRuntimeImpl(com.espertech.esper.common.client.configuration.Configuration configuration, String runtimeURI, Map<String,EPRuntimeSPI> runtimes) Constructor - initializes services.

Method Summary

Modifier and Type	Method and Description
void	addRuntimeStateListener(EPRuntimeStateListener listener) Add a listener to runtime state changes that receives a before-destroy event.
void	destroy() Destroys the runtime.
protected void	doInitialize(Long startTime) Performs the initialization.
com.espertech.esper.common.client.configuration.Configuration	getConfigurationDeepCopy() Returns a deep-copy of the configuration that is actively in use by the runtime.
Map<String,Object>	getConfigurationTransient() Returns the transient configuration, which are configuration values that are passed by reference (and not by value)
Context	getContext() Provides naming context for public named objects.
com.espertech.esper.common.client.context.EPContextPartitionService	getContextPartitionService() Returns the context partition service, for context partition information
com.espertech.esper.common.client.dataflow.core.EPDataFlowService	getDataFlowService() Returns the data flow service, for managing dataflows
EPDeploymentService	getDeploymentService() Returns the deployment service, for deploying and undeploying compiled modules
EPEventService	getEventService() Returns the event service, for sending events to the runtime and for controlling time
EPEventServiceSPI	getEventServiceSPI()
EPEventTypeService	getEventTypeService() Returns the event type service, for obtaining information on event types
EPFireAndForgetService	getFireAndForgetService() Returns the fire-and-forget service, for executing fire-and-forget queries
com.espertech.esper.common.client.metric.EPMetricsService	getMetricsService() Returns the metrics service, for managing runtime and statement metrics reporting
EPRuntimeCompileReflectiveSPI	getReflectiveCompileSvc()
com.espertech.esper.common.client.render.EPRenderEventService	getRenderEventService() Returns the event rendering service, for rendering events to JSON and XML
ReadWriteLock	getRuntimeInstanceWideLock() Returns the runtime-instance global read-write lock.
com.espertech.esper.common.client.EPCompilerPathable	getRuntimePath() Returns a path object for use by the compiler that represents a snapshot of the EPL objects deployed into the runtime at the time of this call.
EPServicesContext	getServicesContext()
AtomicBoolean	getServiceStatusProvider()
EPRuntimeStatementSelectionSPI	getStatementSelectionSvc()
ThreadingService	getThreadingService()
String	getURI() Returns the runtime URI, or "default" if this is the default runtime.
com.espertech.esper.common.client.variable.EPVariableService	getVariableService() Returns the variable service, for reading and writing variables
void	initialize() Frees any resources associated with this runtime instance, and leaves the runtime instance ready for further use.
void	initialize(Long currentTime)
boolean	isDestroyed() Returns true if the runtime is in destroyed state, or false if not.
com.espertech.esper.common.internal.event.bean.core.BeanEventType	makeBeanAnonymousType(Class clazz)
void	postInitialize() Invoked after an initialize operation.
void	removeAllRuntimeStateListeners() Remove all listeners to runtime state changes.
boolean	removeRuntimeStateListener(EPRuntimeStateListener listener) Removate a listener to runtime state changes.
void	setConfiguration(com.espertech.esper.common.client.configuration.Configuration configuration) Sets runtime configuration information for use in the next initialize.
void	traverseStatements(BiConsumer<EPDeployment,EPStatement> consumer)

Methods inherited from class java.lang.Object

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

Constructor Detail

EPRuntimeImpl

public EPRuntimeImpl(com.espertech.esper.common.client.configuration.Configuration configuration,
                     String runtimeURI,
                     Map<String,EPRuntimeSPI> runtimes)
              throws com.espertech.esper.common.client.configuration.ConfigurationException

Constructor - initializes services.

Parameters:

configuration - is the runtimeconfiguration

runtimeURI - is the runtime URI or "default" (or null which it assumes as "default") if this is the default provider

runtimes - map of URI and runtime

Throws:

com.espertech.esper.common.client.configuration.ConfigurationException - is thrown to indicate a configuraton error

Method Detail

postInitialize

public void postInitialize()

Invoked after an initialize operation.

Specified by:

postInitialize in interface EPRuntimeSPI

setConfiguration

public void setConfiguration(com.espertech.esper.common.client.configuration.Configuration configuration)

Sets runtime configuration information for use in the next initialize.

Specified by:

setConfiguration in interface EPRuntimeSPI

Parameters:

configuration - is the runtimeconfigs

getURI

public String getURI()

Description copied from interface: EPRuntime

Returns the runtime URI, or "default" if this is the default runtime.

Specified by:

getURI in interface EPRuntime

Returns:

runtime URI

getEventService

public EPEventService getEventService()

Description copied from interface: EPRuntime

Returns the event service, for sending events to the runtime and for controlling time

Specified by:

getEventService in interface EPRuntime

Returns:

event service

getDeploymentService

public EPDeploymentService getDeploymentService()

Description copied from interface: EPRuntime

Returns the deployment service, for deploying and undeploying compiled modules

Specified by:

getDeploymentService in interface EPRuntime

Returns:

deployment service

getServicesContext

public EPServicesContext getServicesContext()

Specified by:

getServicesContext in interface EPRuntimeSPI

getConfigurationDeepCopy

public com.espertech.esper.common.client.configuration.Configuration getConfigurationDeepCopy()

Description copied from interface: EPRuntime

Returns a deep-copy of the configuration that is actively in use by the runtime.

Note: This can be an expensive operation.

Specified by:

getConfigurationDeepCopy in interface EPRuntime

Returns:

deep copy of the configuration

getConfigurationTransient

public Map<String,Object> getConfigurationTransient()

Description copied from interface: EPRuntime

Returns the transient configuration, which are configuration values that are passed by reference (and not by value)

Specified by:

getConfigurationTransient in interface EPRuntime

Returns:

transient configuration

destroy

public void destroy()

Description copied from interface: EPRuntime

Destroys the runtime.

Releases any resources held by the runtime. The runtime enteres a state in which operations provided by the runtime are not guaranteed to operate properly.

Removes the runtime URI from the known URIs. Allows configuration to change for the instance.

When destroying a runtime your application must make sure that threads that are sending events into the runtime have completed their work. More generally, the runtime should not be currently in use during or after the destroy operation.

Specified by:

destroy in interface EPRuntime

isDestroyed

public boolean isDestroyed()

Description copied from interface: EPRuntime

Returns true if the runtime is in destroyed state, or false if not.

Specified by:

isDestroyed in interface EPRuntime

Returns:

indicator whether the runtime has been destroyed

initialize

public void initialize()

Description copied from interface: EPRuntime

Frees any resources associated with this runtime instance, and leaves the runtime instance ready for further use.

Do not use the EPDeploymentService administrative and EPEventService runtime instances obtained before the initialize (including related services such as configuration, module management, etc.). Your application must obtain new administrative and runtime instances.

Retains the existing configuration of the runtime instance but forgets any runtime configuration changes.

Stops and destroys any existing statement resources such as filters, patterns, expressions, views.

Specified by:

initialize in interface EPRuntime

initialize

public void initialize(Long currentTime)

Specified by:

initialize in interface EPRuntimeSPI

doInitialize

protected void doInitialize(Long startTime)

Performs the initialization.

Parameters:

startTime - optional start time

getContext

public Context getContext()

Description copied from interface: EPRuntime

Provides naming context for public named objects.

An extension point designed for use by input and output adapters as well as other extension services.

Specified by:

getContext in interface EPRuntime

Returns:

naming context providing name-to-object bindings

getRuntimeInstanceWideLock

public ReadWriteLock getRuntimeInstanceWideLock()

Description copied from interface: EPRuntime

Returns the runtime-instance global read-write lock. The send-event methods takes a read lock. The EPDeploymentService.deploy(EPCompiled) and EPDeploymentService.undeploy(String) methods take a write lock.

Specified by:

getRuntimeInstanceWideLock in interface EPRuntime

Returns:

runtime instance global read-write lock

getServiceStatusProvider

public AtomicBoolean getServiceStatusProvider()

Specified by:

getServiceStatusProvider in interface EPRuntimeSPI

addRuntimeStateListener

public void addRuntimeStateListener(EPRuntimeStateListener listener)

Description copied from interface: EPRuntime

Add a listener to runtime state changes that receives a before-destroy event. The listener collection applies set-semantics.

Specified by:

addRuntimeStateListener in interface EPRuntime

Parameters:

listener - to add

removeRuntimeStateListener

public boolean removeRuntimeStateListener(EPRuntimeStateListener listener)

Description copied from interface: EPRuntime

Removate a listener to runtime state changes.

Specified by:

removeRuntimeStateListener in interface EPRuntime

Parameters:

listener - to remove

Returns:

true to indicate the listener was removed, or fals

getEventServiceSPI

public EPEventServiceSPI getEventServiceSPI()

Specified by:

getEventServiceSPI in interface EPRuntimeSPI

removeAllRuntimeStateListeners

public void removeAllRuntimeStateListeners()

Description copied from interface: EPRuntime

Remove all listeners to runtime state changes.

Specified by:

removeAllRuntimeStateListeners in interface EPRuntime

getDataFlowService

public com.espertech.esper.common.client.dataflow.core.EPDataFlowService getDataFlowService()

Description copied from interface: EPRuntime

Returns the data flow service, for managing dataflows

Specified by:

getDataFlowService in interface EPRuntime

Returns:

data flow service

getContextPartitionService

public com.espertech.esper.common.client.context.EPContextPartitionService getContextPartitionService()

Description copied from interface: EPRuntime

Returns the context partition service, for context partition information

Specified by:

getContextPartitionService in interface EPRuntime

Returns:

context partition service

getVariableService

public com.espertech.esper.common.client.variable.EPVariableService getVariableService()

Description copied from interface: EPRuntime

Returns the variable service, for reading and writing variables

Specified by:

getVariableService in interface EPRuntime

Returns:

variable service

getMetricsService

public com.espertech.esper.common.client.metric.EPMetricsService getMetricsService()

Description copied from interface: EPRuntime

Returns the metrics service, for managing runtime and statement metrics reporting

Specified by:

getMetricsService in interface EPRuntime

Returns:

metrics service

getEventTypeService

public EPEventTypeService getEventTypeService()

Description copied from interface: EPRuntime

Returns the event type service, for obtaining information on event types

Specified by:

getEventTypeService in interface EPRuntime

Returns:

event type service

getRenderEventService

public com.espertech.esper.common.client.render.EPRenderEventService getRenderEventService()

Description copied from interface: EPRuntime

Returns the event rendering service, for rendering events to JSON and XML

Specified by:

getRenderEventService in interface EPRuntime

Returns:

render event service

getFireAndForgetService

public EPFireAndForgetService getFireAndForgetService()

Description copied from interface: EPRuntime

Returns the fire-and-forget service, for executing fire-and-forget queries

Specified by:

getFireAndForgetService in interface EPRuntime

Returns:

fire-and-forget service

getThreadingService

public ThreadingService getThreadingService()

Specified by:

getThreadingService in interface EPRuntimeSPI

getRuntimePath

public com.espertech.esper.common.client.EPCompilerPathable getRuntimePath()

Description copied from interface: EPRuntime

Returns a path object for use by the compiler that represents a snapshot of the EPL objects deployed into the runtime at the time of this call. The EPL objects deployed after a call to this method are not included.

Specified by:

getRuntimePath in interface EPRuntime

Returns:

path

traverseStatements

public void traverseStatements(BiConsumer<EPDeployment,EPStatement> consumer)

Specified by:

traverseStatements in interface EPRuntimeSPI

getStatementSelectionSvc

public EPRuntimeStatementSelectionSPI getStatementSelectionSvc()

Specified by:

getStatementSelectionSvc in interface EPRuntimeSPI

getReflectiveCompileSvc

public EPRuntimeCompileReflectiveSPI getReflectiveCompileSvc()

Specified by:

getReflectiveCompileSvc in interface EPRuntimeSPI

makeBeanAnonymousType

public com.espertech.esper.common.internal.event.bean.core.BeanEventType makeBeanAnonymousType(Class clazz)