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

Class EPDeploymentServiceImpl

java.lang.Object

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

All Implemented Interfaces:

EPDeploymentService, EPDeploymentServiceSPI

public class EPDeploymentServiceImpl
extends Object
implements EPDeploymentServiceSPI

Method Summary

Modifier and Type	Method and Description
void	addDeploymentStateListener(DeploymentStateListener listener) Add a deployment state listener
EPDeployment	deploy(com.espertech.esper.common.client.EPCompiled compiled) Deploy a compiled module and with the default options.
EPDeployment	deploy(com.espertech.esper.common.client.EPCompiled compiled, DeploymentOptions options) Deploy a compiled module and with the provided options.
void	destroy()
EPDeployment	getDeployment(String deploymentId) Returns the deployment.
Map<String,DeploymentInternal>	getDeploymentMap()
String[]	getDeployments() Returns the deployment ids of all deployments.
Iterator<DeploymentStateListener>	getDeploymentStateListeners() Returns an iterator of deployment state listeners (read-only)
EPStatement	getStatement(String deploymentId, String statementName) Returns the statement of a given deployment.
boolean	isDeployed(String deploymentId) Returns indicator whether a deployment for this deployment id exists
void	removeAllDeploymentStateListeners() Removes all deployment state listener
void	removeDeploymentStateListener(DeploymentStateListener listener) Remove a deployment state listener
void	undeploy(String deploymentId) Undeploy a deployment and with the default options.
void	undeploy(String deploymentId, UndeploymentOptions options) Undeploy a deployment and with the provided options
void	undeployAll() Undeploy all deployments and with the default options.
void	undeployAll(UndeploymentOptions options) Undeploy all deployments and with the provided options.

Methods inherited from class java.lang.Object

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

Method Detail

deploy

public EPDeployment deploy(com.espertech.esper.common.client.EPCompiled compiled)
                    throws EPDeployException

Description copied from interface: EPDeploymentService

Deploy a compiled module and with the default options.

Specified by:

deploy in interface EPDeploymentService

Parameters:

compiled - byte code

Returns:

deployment

Throws:

EPDeployException - when the deployment failed

deploy

public EPDeployment deploy(com.espertech.esper.common.client.EPCompiled compiled,
                           DeploymentOptions options)
                    throws EPDeployException

Description copied from interface: EPDeploymentService

Deploy a compiled module and with the provided options.

Specified by:

deploy in interface EPDeploymentService

Parameters:

compiled - byte code

options - deployment options

Returns:

deployment

Throws:

EPDeployException - when the deployment failed

getStatement

public EPStatement getStatement(String deploymentId,
                                String statementName)

Description copied from interface: EPDeploymentService

Returns the statement of a given deployment.

A statement is uniquely identified by the deployment id that deployed the statement and by the statement name.

Specified by:

getStatement in interface EPDeploymentService

Parameters:

deploymentId - deployment id of the statement

statementName - statement name

Returns:

statement or null if the statement could not be found

getDeployments

public String[] getDeployments()

Description copied from interface: EPDeploymentService

Returns the deployment ids of all deployments.

Specified by:

getDeployments in interface EPDeploymentService

Returns:

deployment ids

getDeploymentMap

public Map<String,DeploymentInternal> getDeploymentMap()

Specified by:

getDeploymentMap in interface EPDeploymentServiceSPI

getDeployment

public EPDeployment getDeployment(String deploymentId)

Description copied from interface: EPDeploymentService

Returns the deployment.

A deployment is uniquely identified by its deployment id.

Specified by:

getDeployment in interface EPDeploymentService

Parameters:

deploymentId - the deployment id of the deployment

Returns:

deployment or null if the deployment could not be found

isDeployed

public boolean isDeployed(String deploymentId)

Description copied from interface: EPDeploymentService

Returns indicator whether a deployment for this deployment id exists

Specified by:

isDeployed in interface EPDeploymentService

Parameters:

deploymentId - deployment id

Returns:

true for deployed, false for not deployed

undeployAll

public void undeployAll()
                 throws EPUndeployException

Description copied from interface: EPDeploymentService

Undeploy all deployments and with the default options.

Specified by:

undeployAll in interface EPDeploymentService

Throws:

EPUndeployException - when the undeployment failed, of the deployments may remain deployed

undeployAll

public void undeployAll(UndeploymentOptions options)
                 throws EPUndeployException

Description copied from interface: EPDeploymentService

Undeploy all deployments and with the provided options.

Specified by:

undeployAll in interface EPDeploymentService

Parameters:

options - undeployment options or null if none provided

Throws:

EPUndeployException - when the undeployment failed, of the deployments may remain deployed

undeploy

public void undeploy(String deploymentId)
              throws EPUndeployException

Description copied from interface: EPDeploymentService

Undeploy a deployment and with the default options.

Specified by:

undeploy in interface EPDeploymentService

Parameters:

deploymentId - of the deployment to undeploy

Throws:

EPUndeployException - when the deployment does not exist or the undeployment failed and the deployment remains deployed

undeploy

public void undeploy(String deploymentId,
                     UndeploymentOptions options)
              throws EPUndeployException

Description copied from interface: EPDeploymentService

Undeploy a deployment and with the provided options

Specified by:

undeploy in interface EPDeploymentService

Parameters:

deploymentId - of the deployment to undeploy

options - undeployment options

Throws:

EPUndeployException - when the deployment does not exist or the undeployment failed and the deployment remains deployed

destroy

public void destroy()

Specified by:

destroy in interface EPDeploymentServiceSPI

addDeploymentStateListener

public void addDeploymentStateListener(DeploymentStateListener listener)

Description copied from interface: EPDeploymentService

Add a deployment state listener

Specified by:

addDeploymentStateListener in interface EPDeploymentService

Parameters:

listener - to add

removeDeploymentStateListener

public void removeDeploymentStateListener(DeploymentStateListener listener)

Description copied from interface: EPDeploymentService

Remove a deployment state listener

Specified by:

removeDeploymentStateListener in interface EPDeploymentService

Parameters:

listener - to remove

getDeploymentStateListeners

public Iterator<DeploymentStateListener> getDeploymentStateListeners()

Description copied from interface: EPDeploymentService

Returns an iterator of deployment state listeners (read-only)

Specified by:

getDeploymentStateListeners in interface EPDeploymentService

Returns:

listeners

removeAllDeploymentStateListeners

public void removeAllDeploymentStateListeners()

Description copied from interface: EPDeploymentService

Removes all deployment state listener

Specified by:

removeAllDeploymentStateListeners in interface EPDeploymentService