Package com.espertech.esper.runtime.internal.deploymentlifesvc

Class DeploymentLifecycleServiceImpl

java.lang.Object

com.espertech.esper.runtime.internal.deploymentlifesvc.DeploymentLifecycleServiceImpl

All Implemented Interfaces:

DeploymentLifecycleService

public class DeploymentLifecycleServiceImpl
extends Object
implements DeploymentLifecycleService

Constructor Summary

Constructors

Constructor	Description
DeploymentLifecycleServiceImpl(int stageId)

Method Summary

Modifier and Type	Method	Description
void	addDeployment(String deploymentId, DeploymentInternal deployment)
void	addStatementLifecycleListener(StatementListenerEventObserver observer)
void	dispatchStatementListenerEvent(StatementListenerEvent event)
DeploymentInternal	getDeploymentByCRC(long deploymentId)
DeploymentInternal	getDeploymentById(String deploymentId)
String[]	getDeploymentIds()
Map<String,DeploymentInternal>	getDeploymentMap()
CopyOnWriteArrayList<DeploymentStateListener>	getListeners()
EPStatement	getStatementByName(String deploymentId, String statementName)
DeploymentInternal	removeDeployment(String deploymentId)
void	removeStatementLifecycleListener(StatementListenerEventObserver observer)

Methods inherited from class java.lang.Object

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

Constructor Details

DeploymentLifecycleServiceImpl

public DeploymentLifecycleServiceImpl(int stageId)

Method Details

addDeployment

public void addDeployment(String deploymentId,
 DeploymentInternal deployment)

Specified by:

addDeployment in interface DeploymentLifecycleService

getDeploymentIds

public String[] getDeploymentIds()

Specified by:

getDeploymentIds in interface DeploymentLifecycleService

removeDeployment

public DeploymentInternal removeDeployment(String deploymentId)

Specified by:

removeDeployment in interface DeploymentLifecycleService

getDeploymentByCRC

public DeploymentInternal getDeploymentByCRC(long deploymentId)

Specified by:

getDeploymentByCRC in interface DeploymentLifecycleService

getDeploymentById

public DeploymentInternal getDeploymentById(String deploymentId)

Specified by:

getDeploymentById in interface DeploymentLifecycleService

getStatementByName

public EPStatement getStatementByName(String deploymentId,
 String statementName)

Specified by:

getStatementByName in interface DeploymentLifecycleService

getDeploymentMap

public Map<String,DeploymentInternal> getDeploymentMap()

Specified by:

getDeploymentMap in interface DeploymentLifecycleService

getListeners

public CopyOnWriteArrayList<DeploymentStateListener> getListeners()

Specified by:

getListeners in interface DeploymentLifecycleService

addStatementLifecycleListener

public void addStatementLifecycleListener(StatementListenerEventObserver observer)

Specified by:

addStatementLifecycleListener in interface DeploymentLifecycleService

removeStatementLifecycleListener

public void removeStatementLifecycleListener(StatementListenerEventObserver observer)

Specified by:

removeStatementLifecycleListener in interface DeploymentLifecycleService

dispatchStatementListenerEvent

public void dispatchStatementListenerEvent(StatementListenerEvent event)

Specified by:

dispatchStatementListenerEvent in interface DeploymentLifecycleService