| 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.
|
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.
|
| 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 |
| 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.
|
WorkerImpl(Config config,
Collection<String> queues,
JobFactory jobFactory,
redis.clients.jedis.Jedis jedis)
Creates a new WorkerImpl, with the given connection to Redis.
|
WorkerImplFactory(Config config,
Collection<String> queues,
JobFactory jobFactory)
Create a new factory.
|
Copyright © 2011-2015. All Rights Reserved.