org.resoa.persistence.journal.service

Class TaskService

java.lang.Object

org.resoa.persistence.journal.service.TaskService

public class TaskService
extends java.lang.Object

Task Processing service used within a Resoa Grid

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SERVICE_ONMASTERCANCEL Service method name for CANCEL's caused by exceptions during MASTER storage processing
static java.lang.String	SERVICE_PERSISTENCEERROR Service method name for indicating serious persistence errors during final processing (potentially database corrupted or disk full)
static java.lang.String	SERVICE_PROCESS Service method name for PROCESS
static java.lang.String	SERVICE_SLAVETIMEOUT Service invoked in case of a SLAVE request timeout Nodes register a Cancel within execution engine to avoid a delayed commit.

Constructor Summary

Constructors

Constructor and Description
TaskService()

Method Summary

Methods

Modifier and Type	Method and Description
void	onMasterCancel(Task task, org.resoa.node.ResoaResponse response, org.resoa.node.ResoaGateway resoaGW) TASK CANCEL by MASTER in case of any exception
void	onSlaveTimeout(Task task, org.resoa.node.ResoaResponse response, org.resoa.node.ResoaGateway resoaGW) EXECUTED by domain nodes.
void	persistenceError(Task task, org.resoa.node.ResoaResponse response, org.resoa.node.ResoaGateway resoaGW) TASK PERSISTENCE ERROR invoked if an exception happened during storage/database transactions.
void	process(Task task, org.resoa.node.ResoaResponse response, org.resoa.node.ResoaGateway resoaGW) TASK PROCESS - invoked within Resoa NODE persistence communication

Methods inherited from class java.lang.Object

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

Field Detail

SERVICE_PROCESS

public static java.lang.String SERVICE_PROCESS

Service method name for PROCESS

SERVICE_ONMASTERCANCEL

public static java.lang.String SERVICE_ONMASTERCANCEL

Service method name for CANCEL's caused by exceptions during MASTER storage processing

SERVICE_SLAVETIMEOUT

public static java.lang.String SERVICE_SLAVETIMEOUT

Service invoked in case of a SLAVE request timeout Nodes register a Cancel within execution engine to avoid a delayed commit.

SERVICE_PERSISTENCEERROR

public static java.lang.String SERVICE_PERSISTENCEERROR

Service method name for indicating serious persistence errors during final processing (potentially database corrupted or disk full)

Constructor Detail

TaskService

public TaskService()

Method Detail

process

public void process(Task task,
           org.resoa.node.ResoaResponse response,
           org.resoa.node.ResoaGateway resoaGW)

TASK PROCESS - invoked within Resoa NODE persistence communication

Parameters:

task - the task

response - the response

resoaGW - the ResoaGateway

onMasterCancel

public void onMasterCancel(Task task,
                  org.resoa.node.ResoaResponse response,
                  org.resoa.node.ResoaGateway resoaGW)

TASK CANCEL by MASTER in case of any exception

Parameters:

task - the task

response - the response

resoaGW - the ResoaGateway

onSlaveTimeout

public void onSlaveTimeout(Task task,
                  org.resoa.node.ResoaResponse response,
                  org.resoa.node.ResoaGateway resoaGW)

EXECUTED by domain nodes. SLAVE request run into timeout while waiting for MASTER COMMIT Cancellation is registered in MASTER execution engine. Not relevant for LOGFILEPERSIST policy.

Parameters:

task - the task

response - the response

resoaGW - the ResoaGateway

persistenceError

public void persistenceError(Task task,
                    org.resoa.node.ResoaResponse response,
                    org.resoa.node.ResoaGateway resoaGW)

TASK PERSISTENCE ERROR invoked if an exception happened during storage/database transactions. Potentially database corrupted or disk full.

Parameters:

task - the task

response - the response

resoaGW - the ResoaGateway