SpooledDirectoryTransfer (Waarp Common 3.3.4 API Reference)

java.lang.Object
- org.waarp.openr66.client.SpooledDirectoryTransfer

All Implemented Interfaces:

Runnable
```
public class SpooledDirectoryTransfer
extends Object
implements Runnable
```
Direct Transfer from a client with or without database connection or Submit Transfer from a client with database connection to transfer files from a spooled directory to possibly multiple hosts at once.
-to Hosts will have to be separated by ','.
-rule Rule to be used to send files to partners

Mandatory additional elements:
-directory source (directory to spooled on ; many directories can be specified using a comma separated list as "directory1,directory2,directory3")
-statusfile file (file to use as permanent status (if process is killed or aborts))
-stopfile file (file when created will stop the dameon)
Other options:
-info info to be send with the file as filetransfer information
-md5 for md5 option
-block size for block size specification
-nolog to prevent saving action locally
-regex regex (regular expression to filter file names from directory source)
-elapse elapse (elapse time in ms > 100 ms between 2 checks of the directory)
-submit (to submit only: default: only one between submit and direct is allowed)
-direct (to directly transfer only: only one between submit and direct is allowed)
-recursive (to scan recursively from the root)
-waarp WaarpHosts (seperated by ',') to inform of running spooled directory (information stays in memory of Waarp servers, not in database)
-name name to be used as name in list printing in Waarp servers. Note this name must be unique globally.
-elapseWaarp elapse to specify a specific timing > 1000ms between to information sent to Waarp servers (default: 5000ms)
-parallel to allow (default) parallelism between send actions and information
-sequential to not allow parallelism between send actions and information
-limitParallel limit to specify the number of concurrent actions in -direct mode only
-minimalSize limit to specify the minimal size of each file that will be transferred (default: no limit)
-notlogWarn | -logWarn to deactivate or activate (default) the logging in Warn mode of Send/Remove information of the spool

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class SpooledDirectoryTransfer.Arguments
Default arguments

class SpooledDirectoryTransfer.SpooledRunner

Nested Classes
Modifier and Type	Class and Description
`static class`	`SpooledDirectoryTransfer.Arguments` Default arguments
`class`	`SpooledDirectoryTransfer.SpooledRunner`

Field Summary

Fields
Modifier and Type	Field and Description
`protected static String`	`_infoArgs`
`protected static List<SpooledDirectoryTransfer.Arguments>`	`arguments`
`protected int`	`blocksize`
`protected List<String>`	`directory`
`protected long`	`elapseTime`
`protected long`	`elapseWaarpTime`
`static ExecutorService`	`executorService`
`protected String`	`fileInfo`
`protected R66Future`	`future`
`protected boolean`	`ignoreAlreadyUsed`
`protected boolean`	`isMD5`
`protected int`	`limitParallelTasks`
`static List<SpooledDirectoryTransfer>`	`list`
`protected static WaarpLogger`	`logger` Internal Logger
`protected long`	`minimalSize`
`protected FileMonitor`	`monitor`
`String`	`name`
`static String`	`NEEDFULL`
`protected NetworkTransaction`	`networkTransaction`
`static NetworkTransaction`	`networkTransactionStatic`
`protected static String`	`NO_INFO_ARGS`
`protected boolean`	`nolog`
`protected boolean`	`normalInfoAsWarn`
`protected boolean`	`parallel`
`static String`	`PARTIALOK`
`protected boolean`	`recurs`
`protected String`	`regexFilter`
`protected List<String>`	`remoteHosts`
`protected String`	`ruleName`
`protected String`	`statusFile`
`protected String`	`stopFile`
`protected boolean`	`submit`
`protected List<String>`	`waarpHosts`

Constructor Summary

Constructors
Constructor and Description
`SpooledDirectoryTransfer(R66Future future, SpooledDirectoryTransfer.Arguments arguments, NetworkTransaction networkTransaction)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`long`	`getError()`
`protected static boolean`	`getParams(String[] args)` Parse the parameter and set current values
`protected static boolean`	`getParamsFromConfigFile(String filename)`
`long`	`getSent()`
`static boolean`	`initialize(String[] args, boolean normalStart)`
`static void`	`main(String[] args)`
`void`	`run()`
`void`	`stop()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

NEEDFULL
```
public static final String NEEDFULL
```
See Also:

Constant Field Values

PARTIALOK
```
public static final String PARTIALOK
```
See Also:

Constant Field Values

logger

protected static volatile WaarpLogger logger

Internal Logger

_infoArgs
```
protected static String _infoArgs
```

NO_INFO_ARGS

protected static final String NO_INFO_ARGS

See Also:: Constant Field Values

future
```
protected final R66Future future
```

name
```
public final String name
```

directory
```
protected final List<String> directory
```

statusFile
```
protected final String statusFile
```

stopFile
```
protected final String stopFile
```

ruleName
```
protected final String ruleName
```

fileInfo
```
protected final String fileInfo
```

isMD5
```
protected final boolean isMD5
```

remoteHosts

protected final List<String> remoteHosts

regexFilter
```
protected final String regexFilter
```

waarpHosts

protected final List<String> waarpHosts

blocksize
```
protected final int blocksize
```

elapseTime
```
protected final long elapseTime
```

elapseWaarpTime
```
protected final long elapseWaarpTime
```

parallel
```
protected final boolean parallel
```

limitParallelTasks
```
protected final int limitParallelTasks
```

submit
```
protected final boolean submit
```

nolog
```
protected final boolean nolog
```

recurs
```
protected final boolean recurs
```

minimalSize
```
protected final long minimalSize
```

normalInfoAsWarn

protected final boolean normalInfoAsWarn

ignoreAlreadyUsed

protected final boolean ignoreAlreadyUsed

networkTransaction

protected final NetworkTransaction networkTransaction

monitor
```
protected FileMonitor monitor
```

arguments

protected static final List<SpooledDirectoryTransfer.Arguments> arguments

list

public static final List<SpooledDirectoryTransfer> list

networkTransactionStatic

public static NetworkTransaction networkTransactionStatic

executorService

public static ExecutorService executorService

Constructor Detail

SpooledDirectoryTransfer

public SpooledDirectoryTransfer(R66Future future,
                                SpooledDirectoryTransfer.Arguments arguments,
                                NetworkTransaction networkTransaction)

Parameters:: future -; arguments -; networkTransaction -

Method Detail
- run
```
public void run()
```
  Specified by:
  
  run in interface Runnable
- stop
```
public void stop()
```
- getParamsFromConfigFile
```
protected static boolean getParamsFromConfigFile(String filename)
```
- getParams
```
protected static boolean getParams(String[] args)
```
  Parse the parameter and set current values
  
  Parameters:
  
  args -
  
  Returns:
  
  True if all parameters were found and correct
- main
```
public static void main(String[] args)
```
- initialize
```
public static boolean initialize(String[] args,
                                 boolean normalStart)
```
  Parameters:
  
  args -
  
  normalStart - if True, will exit JVM when all daemons are stopped; else False let the caller do (used by SpooledEngine)
- getSent
```
public long getSent()
```
  Returns:
  
  the sent
- getError
```
public long getError()
```
  Returns:
  
  the error

Class SpooledDirectoryTransfer

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

NEEDFULL

PARTIALOK

logger

_infoArgs

NO_INFO_ARGS

future

name

directory

statusFile

stopFile

ruleName

fileInfo

isMD5

remoteHosts

regexFilter

waarpHosts

blocksize

elapseTime

elapseWaarpTime

parallel

limitParallelTasks

submit

nolog

recurs

minimalSize

normalInfoAsWarn

ignoreAlreadyUsed

networkTransaction

monitor

arguments

list

networkTransactionStatic

executorService

Constructor Detail

SpooledDirectoryTransfer

Method Detail

run

stop

getParamsFromConfigFile

getParams

main

initialize

getSent

getError