com.espertech.esper.runtime.client

Interface EPStageService

public interface EPStageService

Stages are used for staging deployments allowing independent control over event and time for subsets of deployments.

This API is under development for version 8.4 and newer, and is considered UNSTABLE.

Stages are uniquely identified by a stage URI.

Use getStage(String) to allocate a stage, of if the stage is already allocated to obtain the stage.

Use getExistingStage(String) to obtain an existing stage without allocating.

Method Summary

Modifier and Type	Method and Description
EPStage	getExistingStage(java.lang.String stageUri) Returns the existing stage for the provided URI, or null if a stage for the URI has not already been allocated.
EPStage	getStage(java.lang.String stageUri) Allocate a new stage or returns the existing stage if the stage for the same URI is already allocated.
java.lang.String[]	getStageURIs() Returns the URI values of all stages that are currently allocated.

Method Detail

getStage

EPStage getStage(java.lang.String stageUri)
          throws EPRuntimeDestroyedException

Allocate a new stage or returns the existing stage if the stage for the same URI is already allocated.

Parameters:

stageUri - unique identifier

Returns:

stage

Throws:

EPRuntimeDestroyedException - if the runtime is already destroyed

getExistingStage

EPStage getExistingStage(java.lang.String stageUri)
                  throws EPRuntimeDestroyedException

Returns the existing stage for the provided URI, or null if a stage for the URI has not already been allocated.

Parameters:

stageUri - stage URI

Returns:

stage

Throws:

EPRuntimeDestroyedException - if the runtime is already destroyed

getStageURIs

java.lang.String[] getStageURIs()
                         throws EPRuntimeDestroyedException

Returns the URI values of all stages that are currently allocated.

Returns:

stage URIs

Throws:

EPRuntimeDestroyedException - if the runtime is already destroyed