org.waarp.openr66.protocol.utils

Class TransferUtils

java.lang.Object

org.waarp.openr66.protocol.utils.TransferUtils

public final class TransferUtils
extends Object

Utility class for transfers

Method Summary

Modifier and Type	Method and Description
static void	cleanOneTransfer(DbTaskRunner taskRunner, Object map, R66Session session, String body) Method to delete the temporary file
static void	cleanSelectedTransfers(DbSession dbSession, int limit, Object map, R66Session session, String body, String startid, String stopid, Timestamp tstart, Timestamp tstop, String rule, String req, boolean pending, boolean transfer, boolean error) Clean all selected transfers
static void	cleanSelectedTransfers(DbSession dbSession, int limit, Object map, R66Session session, String body, String startid, String stopid, Timestamp tstart, Timestamp tstop, String rule, String req, boolean pending, boolean transfer, boolean error, String host)
static void	finalizeTaskWithNoSession(DbTaskRunner taskRunner, LocalChannelReference localChannelReference) Finalize a local task since only Post action has to be done
static R66Result	restartTransfer(DbTaskRunner taskRunner, LocalChannelReference lcr) Try to restart one Transfer Runner Task
static void	stopSelectedTransfers(DbSession dbSession, int limit, Object map, R66Session session, String body, String startid, String stopid, Timestamp tstart, Timestamp tstop, String rule, String req, boolean pending, boolean transfer, boolean error) Stop all selected transfers
static void	stopSelectedTransfers(DbSession dbSession, int limit, Object map, R66Session session, String body, String startid, String stopid, Timestamp tstart, Timestamp tstop, String rule, String req, boolean pending, boolean transfer, boolean error, String host)

Methods inherited from class java.lang.Object

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

Method Detail

restartTransfer

public static R66Result restartTransfer(DbTaskRunner taskRunner,
                                        LocalChannelReference lcr)
                                 throws WaarpDatabaseException

Try to restart one Transfer Runner Task

Parameters:

taskRunner -

Returns:

the associated Result

Throws:

WaarpDatabaseException

finalizeTaskWithNoSession

public static void finalizeTaskWithNoSession(DbTaskRunner taskRunner,
                                             LocalChannelReference localChannelReference)
                                      throws OpenR66RunnerErrorException

Finalize a local task since only Post action has to be done

Parameters:

taskRunner -

localChannelReference -

Throws:

OpenR66RunnerErrorException

stopSelectedTransfers

public static void stopSelectedTransfers(DbSession dbSession,
                                         int limit,
                                         Object map,
                                         R66Session session,
                                         String body,
                                         String startid,
                                         String stopid,
                                         Timestamp tstart,
                                         Timestamp tstop,
                                         String rule,
                                         String req,
                                         boolean pending,
                                         boolean transfer,
                                         boolean error)

Stop all selected transfers

Parameters:

dbSession -

limit -

session -

body -

startid -

stopid -

tstart -

tstop -

rule -

req -

pending -

transfer -

error -

stopSelectedTransfers

public static void stopSelectedTransfers(DbSession dbSession,
                                         int limit,
                                         Object map,
                                         R66Session session,
                                         String body,
                                         String startid,
                                         String stopid,
                                         Timestamp tstart,
                                         Timestamp tstop,
                                         String rule,
                                         String req,
                                         boolean pending,
                                         boolean transfer,
                                         boolean error,
                                         String host)

cleanOneTransfer

public static void cleanOneTransfer(DbTaskRunner taskRunner,
                                    Object map,
                                    R66Session session,
                                    String body)

Method to delete the temporary file

Parameters:

taskRunner -

map -

session -

body -

cleanSelectedTransfers

public static void cleanSelectedTransfers(DbSession dbSession,
                                          int limit,
                                          Object map,
                                          R66Session session,
                                          String body,
                                          String startid,
                                          String stopid,
                                          Timestamp tstart,
                                          Timestamp tstop,
                                          String rule,
                                          String req,
                                          boolean pending,
                                          boolean transfer,
                                          boolean error)

Clean all selected transfers

Parameters:

dbSession -

limit -

map -

session -

body -

startid -

stopid -

tstart -

tstop -

rule -

req -

pending -

transfer -

error -

cleanSelectedTransfers

public static void cleanSelectedTransfers(DbSession dbSession,
                                          int limit,
                                          Object map,
                                          R66Session session,
                                          String body,
                                          String startid,
                                          String stopid,
                                          Timestamp tstart,
                                          Timestamp tstop,
                                          String rule,
                                          String req,
                                          boolean pending,
                                          boolean transfer,
                                          boolean error,
                                          String host)