com.github.cafdataprocessing.utilities.tasksubmitter.taskmessage

Class TaskMessagePublisher

java.lang.Object

com.github.cafdataprocessing.utilities.tasksubmitter.taskmessage.TaskMessagePublisher

public class TaskMessagePublisher
extends Object

Responsible for publishing task messages.

Constructor Summary

Constructors

Constructor and Description
TaskMessagePublisher()

Method Summary

Modifier and Type	Method and Description
static void	publishTaskMessagesForDirectory(String documentInputDirectory, Long workflowId, String projectId, String sentDocumentsDirectory) Constructs and publishes policy worker task messages for files in provided directory.
static ExecutorService	publishTaskMessagesForDirectoryAndMonitor(String documentInputDirectory, Long workflowId, String projectId, String sentDocumentsDirectory) Constructs and publishes policy worker task messages for files in provided directory.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskMessagePublisher

public TaskMessagePublisher()

Method Detail

publishTaskMessagesForDirectoryAndMonitor

public static ExecutorService publishTaskMessagesForDirectoryAndMonitor(String documentInputDirectory,
                                                                        Long workflowId,
                                                                        String projectId,
                                                                        String sentDocumentsDirectory)
                                                                 throws IOException

Constructs and publishes policy worker task messages for files in provided directory. Directory will be monitored and any further file additions will have task messages published also.

Parameters:

documentInputDirectory - Directory to publish messages for.

workflowId - Workflow ID to set on the task data of messages.

projectId - Project ID to set on the task data of messages.

sentDocumentsDirectory - Directory to move files that have had messages sent. Pass null to not move files.

Returns:

ExecutorService monitoring the director for new files.

Throws:

IOException - If errors occurs setting up monitoring for specified directory.

publishTaskMessagesForDirectory

public static void publishTaskMessagesForDirectory(String documentInputDirectory,
                                                   Long workflowId,
                                                   String projectId,
                                                   String sentDocumentsDirectory)

Constructs and publishes policy worker task messages for files in provided directory.

Parameters:

documentInputDirectory - Directory to publish messages for.

workflowId - Workflow ID to set on the task data of messages.

projectId - Project ID to set on the task data of messages.

sentDocumentsDirectory - Directory to move files that have had messages sent. Pass null to not move files.