net.greghaines.jesque.utils

Class JedisUtils

java.lang.Object

net.greghaines.jesque.utils.JedisUtils

public final class JedisUtils
extends Object

A collection of utilities for Redis connections.

Author:

Greg Haines, Animesh Kumar

Field Summary

Fields

Modifier and Type	Field and Description
static String	PONG

Method Summary

Methods

Modifier and Type	Method and Description
static boolean	canUseAsDelayedQueue(redis.clients.jedis.Jedis jedis, String key) Determines if the queue identified by the given key can be used as a delayed queue.
static boolean	canUseAsRecurringQueue(redis.clients.jedis.Jedis jedis, String queueKey, String hashKey)
static boolean	ensureJedisConnection(redis.clients.jedis.Jedis jedis) Ensure that the given connection is established.
static boolean	isDelayedQueue(redis.clients.jedis.Jedis jedis, String key) Determines if the queue identified by the given key is a delayed queue.
static boolean	isKeyUsed(redis.clients.jedis.Jedis jedis, String key) Determines if the queue identified by the given key is used.
static boolean	isRecurringQueue(redis.clients.jedis.Jedis jedis, String queueKey, String hashKey)
static boolean	isRegularQueue(redis.clients.jedis.Jedis jedis, String key) Determines if the queue identified by the given key is a regular queue.
static boolean	reconnect(redis.clients.jedis.Jedis jedis, int reconAttempts, long reconnectSleepTime) Attempt to reconnect to Redis.
static boolean	testJedisConnection(redis.clients.jedis.Jedis jedis) Test if a connection is valid.

Methods inherited from class java.lang.Object

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

Field Detail

PONG

public static final String PONG

See Also:

Constant Field Values

Method Detail

ensureJedisConnection

public static boolean ensureJedisConnection(redis.clients.jedis.Jedis jedis)

Ensure that the given connection is established.

Parameters:

jedis - a connection to Redis

Returns:

true if the supplied connection was already connected

testJedisConnection

public static boolean testJedisConnection(redis.clients.jedis.Jedis jedis)

Test if a connection is valid.

Parameters:

jedis - a connection to Redis

Returns:

true if the supplied connection is connected

reconnect

public static boolean reconnect(redis.clients.jedis.Jedis jedis,
                int reconAttempts,
                long reconnectSleepTime)

Attempt to reconnect to Redis.

Parameters:

jedis - the connection to Redis

reconAttempts - number of times to attempt to reconnect before giving up

reconnectSleepTime - time in milliseconds to wait between attempts

Returns:

true if reconnection was successful

isRegularQueue

public static boolean isRegularQueue(redis.clients.jedis.Jedis jedis,
                     String key)

Determines if the queue identified by the given key is a regular queue.

Parameters:

jedis - connection to Redis

key - the key that identifies a queue

Returns:

true if the key identifies a regular queue, false otherwise

isDelayedQueue

public static boolean isDelayedQueue(redis.clients.jedis.Jedis jedis,
                     String key)

Determines if the queue identified by the given key is a delayed queue.

Parameters:

jedis - connection to Redis

key - the key that identifies a queue

Returns:

true if the key identifies a delayed queue, false otherwise

isRecurringQueue

public static boolean isRecurringQueue(redis.clients.jedis.Jedis jedis,
                       String queueKey,
                       String hashKey)

isKeyUsed

public static boolean isKeyUsed(redis.clients.jedis.Jedis jedis,
                String key)

Determines if the queue identified by the given key is used.

Parameters:

jedis - connection to Redis

key - the key that identifies a queue

Returns:

true if the key is used, false otherwise

canUseAsDelayedQueue

public static boolean canUseAsDelayedQueue(redis.clients.jedis.Jedis jedis,
                           String key)

Determines if the queue identified by the given key can be used as a delayed queue.

Parameters:

jedis - connection to Redis

key - the key that identifies a queue

Returns:

true if the key already is a delayed queue or is not currently used, false otherwise

canUseAsRecurringQueue

public static boolean canUseAsRecurringQueue(redis.clients.jedis.Jedis jedis,
                             String queueKey,
                             String hashKey)