com.whitestein.lsps.engine

Class ProcessAgentImpl

java.lang.Object

com.whitestein.lsps.common.SecureAndLoggingService

com.whitestein.lsps.engine.ProcessAgentImpl

All Implemented Interfaces:

ProcessAgent, javax.ejb.TimedObject

@RunAs(value="processAgent")
 @PermitAll
 @DeclareRoles(value="processAgent")
public class ProcessAgentImpl
extends com.whitestein.lsps.common.SecureAndLoggingService
implements ProcessAgent, javax.ejb.TimedObject

Agent interpreting ProcessModel.

Author:

rba

Field Summary

Fields inherited from class com.whitestein.lsps.common.SecureAndLoggingService

PRINCIPAL_KEY

Fields inherited from interface com.whitestein.lsps.engine.ProcessAgent

MESSAGE_SELECTOR_PROPERTY

Constructor Summary

Constructors

Constructor and Description
ProcessAgentImpl() Creates new instance.
ProcessAgentImpl(ModelInstanceDao modelInstanceDao, ModelProviderService modelProviderService, CommunicationService communicationService, ProcessLogDao processLogDao, UnprocessedInputsService unprocessedInputsService, javax.ejb.SessionContext sessionContext, javax.ejb.TimerService timerService) Creates new instance.

Method Summary

Modifier and Type	Method and Description
void	ejbTimeout(javax.ejb.Timer timer)
ExecutionTrace	handleCommUnit(CommunicationUnit communicationUnit) Handles a communication unit.
ExecutionTrace	handleCommUnitInNewTransaction(CommunicationUnit communicationUnit) Handles a communication unit in a new transaction.
ExecutionTrace	handleCommUnitWithDeadlockRetry(CommunicationUnit communicationUnit) Handles a communication unit in a new transaction with retrying in case of deadlock
ExecutionTrace	handleCommUnitWithErrorHandling(CommunicationUnit communicationUnit) Handles a communication unit with error-handling.
void	initTimers() This method is called from the com.whitestein.lsps.tools.InitServiceImpl at the application startup.
void	terminateOnModelChange(ModelInstance modelInstance)

Methods inherited from class com.whitestein.lsps.common.SecureAndLoggingService

getCurrentTransactionData, getOriginalPrincipal, getSecurityManagerService

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessAgentImpl

public ProcessAgentImpl()

Creates new instance.

ProcessAgentImpl

public ProcessAgentImpl(ModelInstanceDao modelInstanceDao,
                        ModelProviderService modelProviderService,
                        CommunicationService communicationService,
                        ProcessLogDao processLogDao,
                        UnprocessedInputsService unprocessedInputsService,
                        javax.ejb.SessionContext sessionContext,
                        javax.ejb.TimerService timerService)

Creates new instance.

Parameters:

modelInstanceDao -

modelProviderService -

communicationService -

processLogDao -

unprocessedInputsService -

sessionContext -

timerService -

Throws:

java.lang.NullPointerException - if any of the arguments is null

Method Detail

handleCommUnit

public ExecutionTrace handleCommUnit(CommunicationUnit communicationUnit)
                              throws ModelInstanceNotFoundException,
                                     InvalidModelInstanceStateException,
                                     ErrorException

Description copied from interface: ProcessAgent

Handles a communication unit.

Specified by:

handleCommUnit in interface ProcessAgent

Returns:

the result

Throws:

ModelInstanceNotFoundException

InvalidModelInstanceStateException

ErrorException

handleCommUnitInNewTransaction

public ExecutionTrace handleCommUnitInNewTransaction(CommunicationUnit communicationUnit)
                                              throws ModelInstanceNotFoundException,
                                                     InvalidModelInstanceStateException,
                                                     ErrorException

Description copied from interface: ProcessAgent

Handles a communication unit in a new transaction.

Specified by:

handleCommUnitInNewTransaction in interface ProcessAgent

Returns:

the result

Throws:

ModelInstanceNotFoundException

InvalidModelInstanceStateException

ErrorException

handleCommUnitWithDeadlockRetry

public ExecutionTrace handleCommUnitWithDeadlockRetry(CommunicationUnit communicationUnit)
                                               throws java.lang.Exception

Description copied from interface: ProcessAgent

Handles a communication unit in a new transaction with retrying in case of deadlock

Specified by:

handleCommUnitWithDeadlockRetry in interface ProcessAgent

Returns:

the result

Throws:

ModelInstanceNotFoundException

InvalidModelInstanceStateException

java.lang.Exception

handleCommUnitWithErrorHandling

public ExecutionTrace handleCommUnitWithErrorHandling(CommunicationUnit communicationUnit)

Description copied from interface: ProcessAgent

Handles a communication unit with error-handling.

Specified by:

handleCommUnitWithErrorHandling in interface ProcessAgent

Returns:

the result

ejbTimeout

public void ejbTimeout(javax.ejb.Timer timer)

Specified by:

ejbTimeout in interface javax.ejb.TimedObject

initTimers

public void initTimers()

Description copied from interface: ProcessAgent

This method is called from the com.whitestein.lsps.tools.InitServiceImpl at the application startup. Loads all timer notification entries from database and register them again with system timer service.

Specified by:

initTimers in interface ProcessAgent

terminateOnModelChange

public void terminateOnModelChange(ModelInstance modelInstance)

Specified by:

terminateOnModelChange in interface ProcessAgent