com.onionnetworks.antflow.job
Class DirectoryHotFolderJob

java.lang.Object
  com.onionnetworks.antflow.job.HotFolderJob
      com.onionnetworks.antflow.job.DirectoryHotFolderJob

All Implemented Interfaces:

Job

public class DirectoryHotFolderJob

extends HotFolderJob

This job invokes a directory hot folder on a task directory.

Author:

Ry4an Brase (ry4an@ry4an.org)

Nested Class Summary

static class

DirectoryHotFolderJob.AcceptRejectFileFilter Allows for a single UNIX/DOS wildcard pattern for each accept and reject and filters filees based on their name only.

Field Summary

static java.lang.String

JOB_TYPE

Fields inherited from class com.onionnetworks.antflow.job.HotFolderJob

DONE_MODES, PARAM_ACCEPT, PARAM_CHECK_HASH, PARAM_DONE_MODE, PARAM_IGNORE_EMPTY, PARAM_INBOX_DIR, PARAM_MAX_FIRE_QUANTITY, PARAM_MIN_AGE, PARAM_PATTERN, PARAM_REJECT, PARAM_THREADS, red, timer

Fields inherited from interface com.onionnetworks.antflow.job.Job

PARAM_TYPE

Constructor Summary

DirectoryHotFolderJob(com.onionnetworks.util.InvokingDispatch r, java.util.Timer t)

Method Summary

void	go(ExecutorFactory executorFactory, java.io.File taskDir, java.util.Map args, WorkflowContext wfc) Creates a DirectoryHotFolder for the task and does a scanNow().
static void	main(java.lang.String[] args)

Methods inherited from class com.onionnetworks.antflow.job.HotFolderJob

parseParams

Methods inherited from class java.lang.Object

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

Field Detail

JOB_TYPE

public static final java.lang.String JOB_TYPE

See Also:

Constant Field Values

Constructor Detail

DirectoryHotFolderJob

public DirectoryHotFolderJob(com.onionnetworks.util.InvokingDispatch r,
                             java.util.Timer t)

Method Detail

go

public void go(ExecutorFactory executorFactory,
               java.io.File taskDir,
               java.util.Map args,
               WorkflowContext wfc)
        throws java.io.IOException

Creates a DirectoryHotFolder for the task and does a scanNow(). Depending on the DONE_MODE he DirectoryHotFolder will reprocess files so the task needs to move them out of the way.

Specified by:

go in interface Job

Specified by:

go in class HotFolderJob

Parameters:

taskDir - directory for the task to which this job is linked

args - any extra arguments provided for job invocation, likely extra text on the cron line

wfc - the WorkflowContext on which to execute tasks

Throws:

java.io.IOException - on problems with taskDir

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception