com.aspc.task.synccommand

Class SyncCommandHandler

java.lang.Object

com.aspc.task.synccommand.SyncCommandHandler

All Implemented Interfaces:

TaskHandler, TaskHandlerV2

public class SyncCommandHandler
extends java.lang.Object
implements TaskHandlerV2

Since:

08 Nov 2018

Author:

Lei Gao

Constructor Summary

Constructors

Constructor and Description
SyncCommandHandler(VirtualDB vdb, java.lang.String className, java.lang.String command, java.lang.String where)

Method Summary

Modifier and Type	Method and Description
void	beginTask(TaskManager manager, Executor executor, java.lang.String parameters) begin the task and process any parameters
void	handleTask(Executor executor, java.lang.String transid, SoapResultSet transRecord) Handles a task notification.
void	handleTaskV2(Executor executor, java.lang.String transid, SoapResultSet rs, long trans_ms) Handles a task notification.
boolean	preHandleTask(java.lang.String transid, long trans_ms) pre handle a task
protected void	processDelete(java.lang.String transid, SoapResultSet rs)

Methods inherited from class java.lang.Object

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

Constructor Detail

SyncCommandHandler

public SyncCommandHandler(@Nonnull
                          VirtualDB vdb,
                          @Nonnull
                          java.lang.String className,
                          @Nonnull
                          java.lang.String command,
                          @Nullable
                          java.lang.String where)

Method Detail

handleTaskV2

public void handleTaskV2(Executor executor,
                         java.lang.String transid,
                         SoapResultSet rs,
                         long trans_ms)
                  throws java.lang.Exception

Description copied from interface: TaskHandlerV2

Handles a task notification.

Specified by:

handleTaskV2 in interface TaskHandlerV2

Parameters:

executor - an Executor object for running sql

transid - the transaction id for this notification

rs - the transaction record for this trnasaction id +--------+--------+--------+----------------+----------+------+-----------+ |trans_id|layer_id|dbclass |global_key |row_uid |action|action_name| +--------+--------+--------+----------------+----------+------+-----------+ | 82115| 1|DBFolder|4295260035~765@1|4295260035|D |Delete | | 82115| 1|DBFolder|4295260038~765@1|4295260038|D |Delete | +--------+--------+--------+----------------+----------+------+-----------+

trans_ms - transaction time in ms

Throws:

java.lang.Exception - a serious problem

beginTask

public void beginTask(TaskManager manager,
                      Executor executor,
                      java.lang.String parameters)
               throws java.lang.Exception

Description copied from interface: TaskHandler

begin the task and process any parameters

Specified by:

beginTask in interface TaskHandler

Parameters:

manager - the task manager

executor - the server connection

parameters - parameters for starting the task

Throws:

java.lang.Exception - a serious problem

processDelete

protected void processDelete(java.lang.String transid,
                             SoapResultSet rs)

preHandleTask

public boolean preHandleTask(java.lang.String transid,
                             long trans_ms)
                      throws java.lang.Exception

Description copied from interface: TaskHandlerV2

pre handle a task

Specified by:

preHandleTask in interface TaskHandlerV2

Returns:

false to stop this task and all afterward tasks

Throws:

java.lang.Exception

handleTask

public void handleTask(Executor executor,
                       java.lang.String transid,
                       SoapResultSet transRecord)
                throws java.lang.Exception

Description copied from interface: TaskHandler

Handles a task notification.

Specified by:

handleTask in interface TaskHandler

Parameters:

executor - an Executor object for running sql

transid - the transaction id for this notification

transRecord - the transaction record for this trnasaction id +--------+--------+--------+----------------+----------+------+-----------+ |trans_id|layer_id|dbclass |global_key |row_uid |action|action_name| +--------+--------+--------+----------------+----------+------+-----------+ | 82115| 1|DBFolder|4295260035~765@1|4295260035|D |Delete | | 82115| 1|DBFolder|4295260038~765@1|4295260038|D |Delete | +--------+--------+--------+----------------+----------+------+-----------+

Throws:

java.lang.Exception - a serious problem