| Package | Description |
|---|---|
| net.greghaines.jesque | |
| net.greghaines.jesque.admin | |
| net.greghaines.jesque.client | |
| net.greghaines.jesque.meta.dao.impl | |
| net.greghaines.jesque.utils | |
| net.greghaines.jesque.worker |
| Modifier and Type | Method and Description |
|---|---|
Config |
ConfigBuilder.build() |
static Config |
ConfigBuilder.getDefaultConfig() |
| Constructor and Description |
|---|
ConfigBuilder(Config startingPoint)
Create a new ConfigBuilder using an existing Config as the starting
point.
|
| Constructor and Description |
|---|
AbstractAdminClient(Config config) |
AdminClientImpl(Config config)
Create a new AdminClientImpl, which creates it's own connection to Redis
using values from the config.
|
AdminClientImpl(Config config,
boolean checkConnectionBeforeUse)
Create a new AdminClientImpl, which creates it's own connection to Redis
using values from the config.
|
AdminClientImpl(Config config,
long initialDelay,
long period,
TimeUnit timeUnit)
Create a new AdminClientImpl, which creates it's own connection to Redis
using values from the config and spawns a thread to ensure the connection
stays open.
|
AdminClientPoolImpl(Config config,
redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool)
Create a new AdminClientPoolImpl using the supplied configuration and connection pool.
|
AdminImpl(Config config)
Create a new AdminImpl which subscribes to
ResqueConstants.ADMIN_CHANNEL, registers the
PauseCommand and ShutdownCommand jobs, and creates a new Jedis connection. |
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,
redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool)
Create a new AdminImpl which subscribes to
ResqueConstants.ADMIN_CHANNEL, registers the
PauseCommand and ShutdownCommand jobs. |
AdminPoolImpl(Config config,
Set<String> channels,
JobFactory jobFactory,
redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool)
Create a new AdminImpl.
|
| Constructor and Description |
|---|
AbstractClient(Config config)
Constructor.
|
ClientImpl(Config config)
Create a new ClientImpl, which creates it's own connection to Redis using
values from the config.
|
ClientImpl(Config config,
boolean checkConnectionBeforeUse)
Create a new ClientImpl, which creates it's own connection to Redis using
values from the config.
|
ClientImpl(Config config,
long initialDelay,
long period,
TimeUnit timeUnit)
Create a new ClientImpl, which creates it's own connection to Redis using
values from the config and spawns a thread to ensure the connection stays
open.
|
ClientPoolImpl(Config config,
redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool)
Create a ClientPoolImpl.
|
| Constructor and Description |
|---|
FailureDAORedisImpl(Config config,
redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool)
Constructor.
|
KeysDAORedisImpl(Config config,
redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool)
Constructor.
|
QueueInfoDAORedisImpl(Config config,
redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool)
Constructor.
|
WorkerInfoDAORedisImpl(Config config,
redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
static redis.clients.util.Pool<redis.clients.jedis.Jedis> |
PoolUtils.createJedisPool(Config jesqueConfig)
A simple helper method that creates a pool of connections to Redis using
the supplied Config and the default pool config.
|
static redis.clients.util.Pool<redis.clients.jedis.Jedis> |
PoolUtils.createJedisPool(Config jesqueConfig,
org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig)
A simple helper method that creates a pool of connections to Redis using
the supplied configurations.
|
| Modifier and Type | Field and Description |
|---|---|
protected Config |
WorkerImpl.config |
protected Config |
WorkerPoolImpl.config |
| 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.