com.espertech.esper.core.service

Interface StatementIsolationService

All Known Implementing Classes:

StatementIsolationServiceImpl

public interface StatementIsolationService

Service for managing statement isolation.

Method Summary

Modifier and Type	Method and Description
void	beginIsolatingStatements(java.lang.String name, int unitId, EPStatement[] stmt) Indicates statements are moved to isolation.
void	beginUnisolatingStatements(java.lang.String name, int unitId, EPStatement[] stmt) Indicates statements are moved out of isolation.
void	commitIsolatingStatements(java.lang.String name, int unitId, EPStatement[] stmt) Indicates statements are have moved to isolation.
void	commitUnisolatingStatements(java.lang.String name, int unitId, EPStatement[] stmt) Indicates statements have been moved out of isolation.
void	destroy() Destroys the servce.
EPServiceProviderIsolated	getIsolationUnit(java.lang.String name, java.lang.Integer optionalUnitId) Returns an isolated service by names, or allocates a new one if none found.
java.lang.String[]	getIsolationUnitNames() Returns all names or currently known isolation services.
void	newStatement(int stmtId, java.lang.String stmtName, EPIsolationUnitServices isolatedServices) Indicates a new statement created in an isolated service.
void	rollbackIsolatingStatements(java.lang.String name, int unitId, EPStatement[] stmt) Indicates statements are have not moved to isolation.
void	rollbackUnisolatingStatements(java.lang.String name, int unitId, EPStatement[] stmt) Indicates statements are not moved out of isolation.

Method Detail

getIsolationUnit

EPServiceProviderIsolated getIsolationUnit(java.lang.String name,
                                           java.lang.Integer optionalUnitId)

Returns an isolated service by names, or allocates a new one if none found.

Parameters:

name - isolated service

optionalUnitId - the unique id assigned to the isolation unit

Returns:

isolated service provider

destroy

void destroy()

Destroys the servce.

getIsolationUnitNames

java.lang.String[] getIsolationUnitNames()

Returns all names or currently known isolation services.

Returns:

names

beginIsolatingStatements

void beginIsolatingStatements(java.lang.String name,
                              int unitId,
                              EPStatement[] stmt)

Indicates statements are moved to isolation.

Parameters:

name - isolated service provider name.

unitId - isolated service provider number.

stmt - statements moved.

commitIsolatingStatements

void commitIsolatingStatements(java.lang.String name,
                               int unitId,
                               EPStatement[] stmt)

Indicates statements are have moved to isolation.

Parameters:

name - isolated service provider name.

unitId - isolated service provider number.

stmt - statements moved.

rollbackIsolatingStatements

void rollbackIsolatingStatements(java.lang.String name,
                                 int unitId,
                                 EPStatement[] stmt)

Indicates statements are have not moved to isolation.

Parameters:

name - isolated service provider name.

unitId - isolated service provider number.

stmt - statements moved.

beginUnisolatingStatements

void beginUnisolatingStatements(java.lang.String name,
                                int unitId,
                                EPStatement[] stmt)

Indicates statements are moved out of isolation.

Parameters:

name - isolated service provider name.

unitId - isolated service provider number.

stmt - statements moved.

commitUnisolatingStatements

void commitUnisolatingStatements(java.lang.String name,
                                 int unitId,
                                 EPStatement[] stmt)

Indicates statements have been moved out of isolation.

Parameters:

name - isolated service provider name.

unitId - isolated service provider number.

stmt - statements moved.

rollbackUnisolatingStatements

void rollbackUnisolatingStatements(java.lang.String name,
                                   int unitId,
                                   EPStatement[] stmt)

Indicates statements are not moved out of isolation.

Parameters:

name - isolated service provider name.

unitId - isolated service provider number.

stmt - statements moved.

newStatement

void newStatement(int stmtId,
                  java.lang.String stmtName,
                  EPIsolationUnitServices isolatedServices)

Indicates a new statement created in an isolated service.

Parameters:

stmtId - statement id

stmtName - statement name

isolatedServices - isolated services