com.github.cafdataprocessing.utilities.tasksubmitter.taskmessage

Class TaskMessageBuilder

java.lang.Object

com.github.cafdataprocessing.utilities.tasksubmitter.taskmessage.TaskMessageBuilder

public class TaskMessageBuilder
extends Object

Utility Class that creates a Policy Worker TaskMessage for each document in the specified directory.

Constructor Summary

Constructors

Constructor and Description
TaskMessageBuilder()

Method Summary

Modifier and Type	Method and Description
static FileAndTaskMessage	buildTaskMessageForDocument(Long workflowId, String projectId, String documentPath) Constructs a task message for the document at specified path.
static List<FileAndTaskMessage>	buildTaskMessagesForDirectory(Long workflowId, String projectId, String directory) Constructs a task message for each file in the defined directory.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskMessageBuilder

public TaskMessageBuilder()

Method Detail

buildTaskMessagesForDirectory

public static List<FileAndTaskMessage> buildTaskMessagesForDirectory(Long workflowId,
                                                                     String projectId,
                                                                     String directory)
                                                              throws com.hpe.caf.api.ConfigurationException,
                                                                     com.hpe.caf.api.CodecException,
                                                                     IOException,
                                                                     com.hpe.caf.api.worker.DataStoreException,
                                                                     InterruptedException

Constructs a task message for each file in the defined directory.

Parameters:

workflowId - The Workflow ID to set on the built task.

projectId - The ProjectId to set on the built task. Workflow ID provided should be under this project ID.

directory - The directory to build a task message per document for.

Returns:

The constructed task messages and their associated files.

Throws:

com.hpe.caf.api.ConfigurationException - If invalid configuration passed.

com.hpe.caf.api.CodecException - If a codec error occurs building a task message.

IOException - If error occurs accessing files in directory.

com.hpe.caf.api.worker.DataStoreException - If error occurs storing data for files.

InterruptedException

buildTaskMessageForDocument

public static FileAndTaskMessage buildTaskMessageForDocument(Long workflowId,
                                                             String projectId,
                                                             String documentPath)
                                                      throws com.hpe.caf.api.ConfigurationException,
                                                             com.hpe.caf.api.CodecException,
                                                             IOException,
                                                             com.hpe.caf.api.worker.DataStoreException

Constructs a task message for the document at specified path.

Parameters:

workflowId - The Workflow ID to set on the built task.

projectId - The ProjectId to set on the built task. Workflow ID provided should be under this project ID.

documentPath - Path to the document to construct task for.

Returns:

Constructed task message and the associated file.

Throws:

com.hpe.caf.api.ConfigurationException - If invalid configuration passed.

com.hpe.caf.api.CodecException - If a codec error occurs building a task message.

IOException - If error occurs accessing the file.

com.hpe.caf.api.worker.DataStoreException - If error occurs storing data for file.