com.hpe.caf.worker.binaryhash

Class BinaryHashWorkerFactory

java.lang.Object

com.hpe.caf.worker.AbstractWorkerFactory<BinaryHashWorkerConfiguration,BinaryHashWorkerTask>

com.hpe.caf.worker.binaryhash.BinaryHashWorkerFactory

All Implemented Interfaces:

com.hpe.caf.api.HealthReporter, com.hpe.caf.api.worker.WorkerFactory

public class BinaryHashWorkerFactory
extends com.hpe.caf.worker.AbstractWorkerFactory<BinaryHashWorkerConfiguration,BinaryHashWorkerTask>

Factory class for creating a BinaryHashWorker.

Constructor Summary

Constructors

Constructor and Description
BinaryHashWorkerFactory(com.hpe.caf.api.ConfigurationSource configSource, com.hpe.caf.api.worker.DataStore store, com.hpe.caf.api.Codec codec)

Method Summary

Modifier and Type	Method and Description
com.hpe.caf.api.worker.Worker	createWorker(BinaryHashWorkerTask task) Create a worker given a task, using DataStore, ConfiguratonSource and Codec passed in the constructor.
String	getInvalidTaskQueue()
protected int	getWorkerApiVersion()
protected String	getWorkerName()
int	getWorkerThreads()
com.hpe.caf.api.HealthResult	healthCheck() BinaryHashWorkerFactory is responsible for calling the health-check to view the status of the worker and this is displayed on Marathon.

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

createWorker, getCodec, getConfiguration, getDataStore, getWorker, getWorkerConfiguration, verifyWorkerTask, verifyWorkerTaskAndSetResponse

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hpe.caf.api.worker.WorkerFactory

getWorker, shutdown

Constructor Detail

BinaryHashWorkerFactory

public BinaryHashWorkerFactory(com.hpe.caf.api.ConfigurationSource configSource,
                               com.hpe.caf.api.worker.DataStore store,
                               com.hpe.caf.api.Codec codec)
                        throws com.hpe.caf.api.worker.WorkerException

Throws:

com.hpe.caf.api.worker.WorkerException

Method Detail

getWorkerName

protected String getWorkerName()

Specified by:

getWorkerName in class com.hpe.caf.worker.AbstractWorkerFactory<BinaryHashWorkerConfiguration,BinaryHashWorkerTask>

getWorkerApiVersion

protected int getWorkerApiVersion()

Specified by:

getWorkerApiVersion in class com.hpe.caf.worker.AbstractWorkerFactory<BinaryHashWorkerConfiguration,BinaryHashWorkerTask>

createWorker

public com.hpe.caf.api.worker.Worker createWorker(BinaryHashWorkerTask task)
                                           throws com.hpe.caf.api.worker.InvalidTaskException

Create a worker given a task, using DataStore, ConfiguratonSource and Codec passed in the constructor.

Specified by:

createWorker in class com.hpe.caf.worker.AbstractWorkerFactory<BinaryHashWorkerConfiguration,BinaryHashWorkerTask>

Parameters:

task -

Returns:

BinaryHashWorker

Throws:

com.hpe.caf.api.worker.InvalidTaskException

getInvalidTaskQueue

public String getInvalidTaskQueue()

getWorkerThreads

public int getWorkerThreads()

healthCheck

public com.hpe.caf.api.HealthResult healthCheck()

BinaryHashWorkerFactory is responsible for calling the health-check to view the status of the worker and this is displayed on Marathon.

Returns:

HealthResult