public class WorkerImplFactory extends Object implements Callable<WorkerImpl>
WorkerImpls. Designed to be used with
WorkerPool.| Constructor and Description |
|---|
WorkerImplFactory(Config config,
Collection<String> queues,
JobFactory jobFactory)
Create a new factory.
|
| Modifier and Type | Method and Description |
|---|---|
WorkerImpl |
call()
Create a new
WorkerImpl using the arguments provided to this
factory's constructor. |
public WorkerImplFactory(Config config, Collection<String> queues, JobFactory jobFactory)
WorkerImpls will use the
provided arguments.config - used to create a connection to Redis and the package prefix
for incoming jobsqueues - the list of queues to polljobFactory - the job factory that materializes the jobspublic WorkerImpl call()
WorkerImpl using the arguments provided to this
factory's constructor.call in interface Callable<WorkerImpl>Copyright © 2011-2015. All Rights Reserved.