com.hpe.caf.worker.binaryhash

Class BinaryHashWorker

java.lang.Object

com.hpe.caf.worker.AbstractWorker<BinaryHashWorkerTask,BinaryHashWorkerResult>

com.hpe.caf.worker.binaryhash.BinaryHashWorker

All Implemented Interfaces:

com.hpe.caf.api.worker.Worker

public class BinaryHashWorker
extends com.hpe.caf.worker.AbstractWorker<BinaryHashWorkerTask,BinaryHashWorkerResult>

Binary Hash worker. This is the class responsible for generating a hash of the input file.

Constructor Summary

Constructors

Constructor and Description
BinaryHashWorker(BinaryHashWorkerTask task, com.hpe.caf.api.worker.DataStore dataStore, String outputQueue, com.hpe.caf.api.Codec codec, long resultSizeThreshold)

Method Summary

Modifier and Type	Method and Description
com.hpe.caf.api.worker.WorkerResponse	doWork() Trigger processing of the source file and determine a response.
int	getWorkerApiVersion()
String	getWorkerIdentifier()

Methods inherited from class com.hpe.caf.worker.AbstractWorker

buildExceptionStackTrace, checkIfInterrupted, createFailureResult, createFailureResult, createSuccessNoOutputToQueue, createSuccessResult, createSuccessResult, createTaskSubmission, createTaskSubmission, getCodec, getGeneralFailureResult, getResultQueue, getTask, stackTraceToString

Methods inherited from class java.lang.Object

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

Constructor Detail

BinaryHashWorker

public BinaryHashWorker(BinaryHashWorkerTask task,
                        com.hpe.caf.api.worker.DataStore dataStore,
                        String outputQueue,
                        com.hpe.caf.api.Codec codec,
                        long resultSizeThreshold)
                 throws com.hpe.caf.api.worker.InvalidTaskException

Throws:

com.hpe.caf.api.worker.InvalidTaskException

Method Detail

getWorkerIdentifier

public String getWorkerIdentifier()

getWorkerApiVersion

public int getWorkerApiVersion()

doWork

public com.hpe.caf.api.worker.WorkerResponse doWork()
                                             throws InterruptedException,
                                                    com.hpe.caf.api.worker.TaskRejectedException

Trigger processing of the source file and determine a response.

Returns:

WorkerResponse - a response from the operation.

Throws:

InterruptedException - - if the task is interrupted.

com.hpe.caf.api.worker.TaskRejectedException