com.github.cafdataprocessing.utilities.taskreceiver.taskmessage

Class TaskMessageWriter

java.lang.Object

com.github.cafdataprocessing.utilities.taskreceiver.taskmessage.TaskMessageWriter

public class TaskMessageWriter
extends Object

Class responsible for output of task messages.

Constructor Summary

Constructors

Constructor and Description
TaskMessageWriter(String outputDirectory, com.hpe.caf.api.worker.ManagedDataStore dataStore, OutputHelper outputHelper, boolean saveTaskDataOnly, boolean cleanupDataStoreAfterwards) Constructs a TaskMessageWriter that will use provided parameters.

Method Summary

Modifier and Type	Method and Description
void	writeMessage(com.hpe.caf.api.worker.TaskMessage taskMessage) Writes out details about the provided task message.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskMessageWriter

public TaskMessageWriter(String outputDirectory,
                         com.hpe.caf.api.worker.ManagedDataStore dataStore,
                         OutputHelper outputHelper,
                         boolean saveTaskDataOnly,
                         boolean cleanupDataStoreAfterwards)

Constructs a TaskMessageWriter that will use provided parameters.

Parameters:

outputDirectory - The directory to output task messages to.

dataStore - DataStore to use in retrieving data referenced in task messages.

outputHelper - OutputHelper for task message output operations.

Method Detail

writeMessage

public void writeMessage(com.hpe.caf.api.worker.TaskMessage taskMessage)
                  throws IOException,
                         com.hpe.caf.api.CodecException

Writes out details about the provided task message.

Parameters:

taskMessage - The task message to output information about.

Throws:

IOException

com.hpe.caf.api.CodecException