net.greghaines.jesque.worker

Class WorkerImplFactory

java.lang.Object

net.greghaines.jesque.worker.WorkerImplFactory

All Implemented Interfaces:

Callable<WorkerImpl>

public class WorkerImplFactory
extends Object
implements Callable<WorkerImpl>

WorkerImplFactory is a factory for WorkerImpls. Designed to be used with WorkerPool.

Constructor Summary

Constructors

Constructor and Description
WorkerImplFactory(Config config, Collection<String> queues, JobFactory jobFactory) Create a new factory.

Method Summary

Modifier and Type	Method and Description
WorkerImpl	call() Create a new WorkerImpl using the arguments provided to this factory's constructor.

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerImplFactory

public WorkerImplFactory(Config config,
                         Collection<String> queues,
                         JobFactory jobFactory)

Create a new factory. Returned WorkerImpls will use the provided arguments.

Parameters:

config - used to create a connection to Redis and the package prefix for incoming jobs

queues - the list of queues to poll

jobFactory - the job factory that materializes the jobs

Method Detail

call

public WorkerImpl call()

Create a new WorkerImpl using the arguments provided to this factory's constructor.

Specified by:

call in interface Callable<WorkerImpl>

Returns:

a new WorkerImpl