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

Method Detail

getIsolationUnit

EPServiceProviderIsolated getIsolationUnit(String name,
                                           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

String[] getIsolationUnitNames()

Returns all names or currently known isolation services.

Returns:

names

beginIsolatingStatements

void beginIsolatingStatements(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(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(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(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(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(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,
                  String stmtName,
                  EPIsolationUnitServices isolatedServices)

Indicates a new statement created in an isolated service.

Parameters:

stmtId - statement id

stmtName - statement name

isolatedServices - isolated services