com.netflix.dyno.queues.redis

Class RedisQueues

java.lang.Object

com.netflix.dyno.queues.redis.RedisQueues

public class RedisQueues
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
RedisQueues(redis.clients.jedis.JedisCommands quorumConn, redis.clients.jedis.JedisCommands nonQuorumConn, java.lang.String redisKeyPrefix, ShardSupplier shardSupplier, int unackTime, int unackHandlerIntervalInMS, int dynoOpThreadCount)

Method Summary

Modifier and Type	Method and Description
DynoQueue	get(java.lang.String queueName)
java.util.Collection<DynoQueue>	queues()

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisQueues

public RedisQueues(redis.clients.jedis.JedisCommands quorumConn,
                   redis.clients.jedis.JedisCommands nonQuorumConn,
                   java.lang.String redisKeyPrefix,
                   ShardSupplier shardSupplier,
                   int unackTime,
                   int unackHandlerIntervalInMS,
                   int dynoOpThreadCount)

Parameters:

quorumConn - Dyno connection with dc_quorum enabled

nonQuorumConn - Dyno connection to local Redis

redisKeyPrefix - prefix applied to the Redis keys

shardSupplier - Provider for the shards for the queues created

unackTime - Time in millisecond within which a message needs to be acknowledged by the client, after which the message is re-queued.

unackHandlerIntervalInMS - Time in millisecond at which the un-acknowledgement processor runs

dynoOpThreadCount - no. of threads that are used to make the calls to dyno. All the queues share the threadpool executor created with this count.

Method Detail

get

public DynoQueue get(java.lang.String queueName)

Parameters:

queueName - Name of the queue

Returns:

Returns the DynoQueue hosting the given queue by name

See Also:

DynoQueue, RedisDynoQueue

queues

public java.util.Collection<DynoQueue> queues()

Returns:

Collection of all the registered queues