com.espertech.esper.core.service

Interface StatementLifecycleSvc

All Superinterfaces:

StatementLifecycleStmtContextResolver

All Known Implementing Classes:

StatementLifecycleSvcImpl

public interface StatementLifecycleSvc
extends StatementLifecycleStmtContextResolver

Handles statement management.

Method Summary

Modifier and Type	Method and Description
void	addObserver(StatementLifecycleObserver observer) Add an observer to be called back when statement-state or listener/subscriber changes are registered.
EPStatement	createAndStart(StatementSpecRaw statementSpec, String expression, boolean isPattern, String optStatementName, Object userObject, EPIsolationUnitServices isolationUnitServices, Integer optionalStatementId, EPStatementObjectModel optionalModel) Create and start the statement.
void	destroy() Destroy the service.
void	destroy(int statementId) Destroy statement by statement id.
void	destroyAllStatements() Destroys all started statements.
void	dispatchStatementLifecycleEvent(StatementLifecycleEvent theEvent) Dispatch event to observers.
EPStatementSPI	getStatementById(int statementId)
EPStatement	getStatementByName(String name) Returns the statement by the given name, or null if no such statement exists.
String	getStatementNameById(int statementId)
String[]	getStatementNames() Returns an array of statement names.
StatementSpecCompiled	getStatementSpec(int statementId)
Map<String,EPStatement>	getStmtNameToStmt()
void	init() Initialized the service before use.
void	removeObserver(StatementLifecycleObserver observer) Remove an observer to be called back when statement-state or listener/subscriber changes are registered.
void	start(int statementId) Start statement by statement id.
void	startAllStatements() Starts all stopped statements.
void	stop(int statementId) Stop statement by statement id.
void	stopAllStatements() Stops all started statements.
void	updatedListeners(EPStatement stmt, EPStatementListenerSet listeners, boolean isRecovery) Statements indicate that listeners have been added through this method.

Methods inherited from interface com.espertech.esper.core.service.StatementLifecycleStmtContextResolver

getStatementContextById

Method Detail

init

void init()

Initialized the service before use.

addObserver

void addObserver(StatementLifecycleObserver observer)

Add an observer to be called back when statement-state or listener/subscriber changes are registered.

The observers list is backed by a Set.

Parameters:

observer - to add

removeObserver

void removeObserver(StatementLifecycleObserver observer)

Remove an observer to be called back when statement-state or listener/subscriber changes are registered.

Parameters:

observer - to remove

dispatchStatementLifecycleEvent

void dispatchStatementLifecycleEvent(StatementLifecycleEvent theEvent)

Dispatch event to observers.

Parameters:

theEvent - to dispatch

createAndStart

EPStatement createAndStart(StatementSpecRaw statementSpec,
                           String expression,
                           boolean isPattern,
                           String optStatementName,
                           Object userObject,
                           EPIsolationUnitServices isolationUnitServices,
                           Integer optionalStatementId,
                           EPStatementObjectModel optionalModel)

Create and start the statement.

Parameters:

statementSpec - is the statement definition in bean object form, raw unvalidated and unoptimized.

expression - is the expression text

isPattern - is an indicator on whether this is a pattern statement and thus the iterator must return the last result, versus for non-pattern statements the iterator returns view content.

optStatementName - is an optional statement name, null if none was supplied

userObject - the application define user object associated to each statement, if supplied

isolationUnitServices - isolated service services

optionalStatementId - the statement id

optionalModel - model

Returns:

started statement

start

void start(int statementId)

Start statement by statement id.

Parameters:

statementId - of the statement to start.

stop

void stop(int statementId)

Stop statement by statement id.

Parameters:

statementId - of the statement to stop.

destroy

void destroy(int statementId)

Destroy statement by statement id.

Parameters:

statementId - statementId of the statement to destroy

getStatementByName

EPStatement getStatementByName(String name)

Returns the statement by the given name, or null if no such statement exists.

Parameters:

name - is the statement name

Returns:

statement for the given name, or null if no such statement existed

getStatementNames

String[] getStatementNames()

Returns an array of statement names. If no statement has been created, an empty array is returned.

Only returns started and stopped statements.

Returns:

statement names

startAllStatements

void startAllStatements()
                 throws EPException

Starts all stopped statements. First statement to fail supplies the exception.

Throws:

EPException - to indicate a start error.

stopAllStatements

void stopAllStatements()
                throws EPException

Stops all started statements. First statement to fail supplies the exception.

Throws:

EPException - to indicate a start error.

destroyAllStatements

void destroyAllStatements()
                   throws EPException

Destroys all started statements. First statement to fail supplies the exception.

Throws:

EPException - to indicate a start error.

updatedListeners

void updatedListeners(EPStatement stmt,
                      EPStatementListenerSet listeners,
                      boolean isRecovery)

Statements indicate that listeners have been added through this method.

Parameters:

stmt - is the statement for which listeners were added

listeners - is the set of listeners after adding the new listener

isRecovery - indicator whether recovering

destroy

void destroy()

Destroy the service.

getStatementNameById

String getStatementNameById(int statementId)

getStmtNameToStmt

Map<String,EPStatement> getStmtNameToStmt()

getStatementById

EPStatementSPI getStatementById(int statementId)

getStatementSpec

StatementSpecCompiled getStatementSpec(int statementId)