com.espertech.esper.core.service

Class StatementIsolationServiceImpl

java.lang.Object

com.espertech.esper.core.service.StatementIsolationServiceImpl

All Implemented Interfaces:

StatementIsolationService

public class StatementIsolationServiceImpl
extends Object
implements StatementIsolationService

Service to maintain currently active isoalted service providers for an engine.

Constructor Summary

Constructors

Constructor and Description
StatementIsolationServiceImpl() Ctor.

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.
void	setEpServicesContext(EPServicesContext epServicesContext) Set the engine service context.

Methods inherited from class java.lang.Object

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

Constructor Detail

StatementIsolationServiceImpl

public StatementIsolationServiceImpl()

Ctor.

Method Detail

setEpServicesContext

public void setEpServicesContext(EPServicesContext epServicesContext)

Set the engine service context.

Parameters:

epServicesContext - services context

getIsolationUnit

public EPServiceProviderIsolated getIsolationUnit(String name,
                                                  Integer optionalUnitId)

Description copied from interface: StatementIsolationService

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

Specified by:

getIsolationUnit in interface StatementIsolationService

Parameters:

name - isolated service

optionalUnitId - the unique id assigned to the isolation unit

Returns:

isolated service provider

destroy

public void destroy()

Description copied from interface: StatementIsolationService

Destroys the servce.

Specified by:

destroy in interface StatementIsolationService

getIsolationUnitNames

public String[] getIsolationUnitNames()

Description copied from interface: StatementIsolationService

Returns all names or currently known isolation services.

Specified by:

getIsolationUnitNames in interface StatementIsolationService

Returns:

names

beginIsolatingStatements

public void beginIsolatingStatements(String name,
                                     int unitId,
                                     EPStatement[] stmt)

Description copied from interface: StatementIsolationService

Indicates statements are moved to isolation.

Specified by:

beginIsolatingStatements in interface StatementIsolationService

Parameters:

name - isolated service provider name.

unitId - isolated service provider number.

stmt - statements moved.

commitIsolatingStatements

public void commitIsolatingStatements(String name,
                                      int unitId,
                                      EPStatement[] stmt)

Description copied from interface: StatementIsolationService

Indicates statements are have moved to isolation.

Specified by:

commitIsolatingStatements in interface StatementIsolationService

Parameters:

name - isolated service provider name.

unitId - isolated service provider number.

stmt - statements moved.

rollbackIsolatingStatements

public void rollbackIsolatingStatements(String name,
                                        int unitId,
                                        EPStatement[] stmt)

Description copied from interface: StatementIsolationService

Indicates statements are have not moved to isolation.

Specified by:

rollbackIsolatingStatements in interface StatementIsolationService

Parameters:

name - isolated service provider name.

unitId - isolated service provider number.

stmt - statements moved.

beginUnisolatingStatements

public void beginUnisolatingStatements(String name,
                                       int unitId,
                                       EPStatement[] stmt)

Description copied from interface: StatementIsolationService

Indicates statements are moved out of isolation.

Specified by:

beginUnisolatingStatements in interface StatementIsolationService

Parameters:

name - isolated service provider name.

unitId - isolated service provider number.

stmt - statements moved.

commitUnisolatingStatements

public void commitUnisolatingStatements(String name,
                                        int unitId,
                                        EPStatement[] stmt)

Description copied from interface: StatementIsolationService

Indicates statements have been moved out of isolation.

Specified by:

commitUnisolatingStatements in interface StatementIsolationService

Parameters:

name - isolated service provider name.

unitId - isolated service provider number.

stmt - statements moved.

rollbackUnisolatingStatements

public void rollbackUnisolatingStatements(String name,
                                          int unitId,
                                          EPStatement[] stmt)

Description copied from interface: StatementIsolationService

Indicates statements are not moved out of isolation.

Specified by:

rollbackUnisolatingStatements in interface StatementIsolationService

Parameters:

name - isolated service provider name.

unitId - isolated service provider number.

stmt - statements moved.

newStatement

public void newStatement(int stmtId,
                         String stmtName,
                         EPIsolationUnitServices isolatedServices)

Description copied from interface: StatementIsolationService

Indicates a new statement created in an isolated service.

Specified by:

newStatement in interface StatementIsolationService

Parameters:

stmtId - statement id

stmtName - statement name

isolatedServices - isolated services