| Package | Description |
|---|---|
| net.greghaines.jesque.admin | |
| net.greghaines.jesque.worker |
| Modifier and Type | Method and Description |
|---|---|
JobFactory |
AdminImpl.getJobFactory()
The job factory.
|
JobFactory |
AdminPoolImpl.getJobFactory()
The job factory.
|
| Constructor and Description |
|---|
AdminImpl(Config config,
Set<String> channels,
JobFactory jobFactory)
Create a new AdminImpl which creates a new Jedis connection.
|
AdminImpl(Config config,
Set<String> channels,
JobFactory jobFactory,
redis.clients.jedis.Jedis jedis)
Create a new AdminImpl.
|
AdminPoolImpl(Config config,
Set<String> channels,
JobFactory jobFactory,
redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool)
Create a new AdminImpl.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MapBasedJobFactory
MapBasedJobFactory uses a map of job names and types to materialize jobs.
|
class |
ReflectiveJobFactory
ReflectiveJobFactory assumes job names are fully-qualified class names.
|
| Modifier and Type | Method and Description |
|---|---|
JobFactory |
JobExecutor.getJobFactory()
The job factory.
|
JobFactory |
WorkerPool.getJobFactory()
The job factory.
|
JobFactory |
WorkerImpl.getJobFactory()
The job factory.
|
JobFactory |
WorkerPoolImpl.getJobFactory()
The job factory.
|
| Constructor and Description |
|---|
WorkerImpl(Config config,
Collection<String> queues,
JobFactory jobFactory)
Creates a new WorkerImpl, which creates it's own connection to Redis using values from the config.
The worker will only listen to the supplied queues and execute jobs that are provided by the given job factory. |
WorkerImpl(Config config,
Collection<String> queues,
JobFactory jobFactory,
redis.clients.jedis.Jedis jedis)
Creates a new WorkerImpl, with the given connection to Redis.
The worker will only listen to the supplied queues and execute jobs that are provided by the given job factory. |
WorkerImpl(Config config,
Collection<String> queues,
JobFactory jobFactory,
redis.clients.jedis.Jedis jedis,
NextQueueStrategy nextQueueStrategy)
Creates a new WorkerImpl, with the given connection to Redis.
The worker will only listen to the supplied queues and execute jobs that are provided by the given job factory. |
WorkerImplFactory(Config config,
Collection<String> queues,
JobFactory jobFactory)
Create a new factory.
|
WorkerPoolImpl(Config config,
Collection<String> queues,
JobFactory jobFactory,
redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool)
Creates a new WorkerImpl, with the given connection to Redis.
The worker will only listen to the supplied queues and execute jobs that are provided by the given job factory. |
WorkerPoolImpl(Config config,
Collection<String> queues,
JobFactory jobFactory,
redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool,
NextQueueStrategy nextQueueStrategy)
Creates a new WorkerImpl, with the given connection to Redis.
The worker will only listen to the supplied queues and execute jobs that are provided by the given job factory. |
WorkerPoolImplFactory(Config config,
Collection<String> queues,
JobFactory jobFactory,
redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool)
Create a new factory.
|
Copyright © 2011–2019. All rights reserved.