com.haulmont.cuba.core.app.execution

Class ExecutionsImpl

java.lang.Object

com.haulmont.cuba.core.app.execution.ExecutionsImpl

All Implemented Interfaces:

Executions

@Component(value="cuba_Executions")
public class ExecutionsImpl
extends java.lang.Object
implements Executions

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ExecutionsImpl.CancelExecutionClusterListener
protected static class	ExecutionsImpl.CancelExecutionMessage

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusterManagerAPI	clusterManager
protected static java.lang.String	EXECUTIONS_ATTR
protected TimeSource	timeSource
protected UserSessionsAPI	userSessionsAPI
protected UserSessionSource	userSessionSource

Fields inherited from interface com.haulmont.cuba.core.app.execution.Executions

NAME

Constructor Summary

Constructors

Constructor and Description
ExecutionsImpl()

Method Summary

Modifier and Type	Method and Description
void	cancelExecution(java.util.UUID userSessionId, java.lang.String group, java.lang.String key) Cancel execution context: - cancel all resources with context.
protected void	cancelLocally(UserSession userSession, java.lang.String group, java.lang.String key)
void	endExecution() INTERNAL End execution context for the current thread.
protected java.util.List<ExecutionContext>	findExecutionContextsByKeyAndGroup(UserSession userSession, java.lang.String group, java.lang.String key)
ExecutionContext	getCurrentContext() INTERNAL
void	init()
protected void	removeExecutionContextFromUserSession(UserSession userSession, ExecutionContext context)
ExecutionContext	startExecution(java.lang.String key, java.lang.String group) INTERNAL Start execution context for the current thread.

Methods inherited from class java.lang.Object

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

Field Detail

EXECUTIONS_ATTR

protected static final java.lang.String EXECUTIONS_ATTR

timeSource

@Inject
protected TimeSource timeSource

userSessionSource

@Inject
protected UserSessionSource userSessionSource

userSessionsAPI

@Inject
protected UserSessionsAPI userSessionsAPI

clusterManager

@Inject
protected ClusterManagerAPI clusterManager

Constructor Detail

ExecutionsImpl

public ExecutionsImpl()

Method Detail

init

@PostConstruct
public void init()

startExecution

public ExecutionContext startExecution(java.lang.String key,
                                       java.lang.String group)

Description copied from interface: Executions

INTERNAL Start execution context for the current thread. Bind execution context to the current thread and user session

Specified by:

startExecution in interface Executions

Parameters:

key - - unique identifier of execution

group - - group is used for grouping execution by type. E.g. group 'Reporting' is used for all reporting module executions

Returns:

created execution context

endExecution

public void endExecution()

Description copied from interface: Executions

INTERNAL End execution context for the current thread. Unbind from user session and thread

Specified by:

endExecution in interface Executions

cancelExecution

public void cancelExecution(java.util.UUID userSessionId,
                            java.lang.String group,
                            java.lang.String key)

Description copied from interface: Executions

Cancel execution context: - cancel all resources with context. E.g. for JDBC cancel executed statements. - interrupt thread of execution context.

Specified by:

cancelExecution in interface Executions

Parameters:

userSessionId - - user session in that started execution context

group - - group of started execution context

key - - key of started execution context

getCurrentContext

public ExecutionContext getCurrentContext()

Description copied from interface: Executions

INTERNAL

Specified by:

getCurrentContext in interface Executions

Returns:

execution context that is bound to the current thread

cancelLocally

protected void cancelLocally(UserSession userSession,
                             java.lang.String group,
                             java.lang.String key)

findExecutionContextsByKeyAndGroup

protected java.util.List<ExecutionContext> findExecutionContextsByKeyAndGroup(UserSession userSession,
                                                                              java.lang.String group,
                                                                              java.lang.String key)

removeExecutionContextFromUserSession

protected void removeExecutionContextFromUserSession(UserSession userSession,
                                                     ExecutionContext context)