A C D E G H M P Q R S T W

A

ack(String) - Method in interface com.netflix.dyno.queues.DynoQueue

Provides an acknowledgement for the message.

ack(String) - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

C

clear() - Method in interface com.netflix.dyno.queues.DynoQueue

Truncates the entire queue.

clear() - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

com.netflix.dyno.queues - package com.netflix.dyno.queues

com.netflix.dyno.queues.redis - package com.netflix.dyno.queues.redis

D

DynoQueue - Interface in com.netflix.dyno.queues

DynoShardSupplier - Class in com.netflix.dyno.queues.redis

DynoShardSupplier(HostSupplier, String, String) - Constructor for class com.netflix.dyno.queues.redis.DynoShardSupplier

E

equals(Object) - Method in class com.netflix.dyno.queues.Message

G

get(String) - Method in interface com.netflix.dyno.queues.DynoQueue

get(String) - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

get(String) - Method in class com.netflix.dyno.queues.redis.RedisQueues

getCurrentShard() - Method in class com.netflix.dyno.queues.redis.DynoShardSupplier

getCurrentShard() - Method in interface com.netflix.dyno.queues.ShardSupplier

getId() - Method in class com.netflix.dyno.queues.Message

getName() - Method in interface com.netflix.dyno.queues.DynoQueue

getName() - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

getPayload() - Method in class com.netflix.dyno.queues.Message

getPriority() - Method in class com.netflix.dyno.queues.Message

getQueueShards() - Method in class com.netflix.dyno.queues.redis.DynoShardSupplier

getQueueShards() - Method in interface com.netflix.dyno.queues.ShardSupplier

getTimeout() - Method in class com.netflix.dyno.queues.Message

getUnackTime() - Method in interface com.netflix.dyno.queues.DynoQueue

getUnackTime() - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

H

hashCode() - Method in class com.netflix.dyno.queues.Message

M

Message - Class in com.netflix.dyno.queues

Message() - Constructor for class com.netflix.dyno.queues.Message

Message(String, String) - Constructor for class com.netflix.dyno.queues.Message

P

peek(int) - Method in interface com.netflix.dyno.queues.DynoQueue

Provides a peek into the queue without taking messages out.

peek(int) - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

pop(int, int, TimeUnit) - Method in interface com.netflix.dyno.queues.DynoQueue

pop(int, int, TimeUnit) - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

processUnacks() - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

push(List<Message>) - Method in interface com.netflix.dyno.queues.DynoQueue

push(List<Message>) - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

Q

QueueMonitor - Class in com.netflix.dyno.queues.redis

queues() - Method in class com.netflix.dyno.queues.redis.RedisQueues

R

RedisDynoQueue - Class in com.netflix.dyno.queues.redis

RedisDynoQueue(String, String, Set<String>, String, ExecutorService) - Constructor for class com.netflix.dyno.queues.redis.RedisDynoQueue

RedisQueues - Class in com.netflix.dyno.queues.redis

RedisQueues(JedisCommands, JedisCommands, String, ShardSupplier, int, int, int) - Constructor for class com.netflix.dyno.queues.redis.RedisQueues

remove(String) - Method in interface com.netflix.dyno.queues.DynoQueue

remove(String) - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

S

setId(String) - Method in class com.netflix.dyno.queues.Message

setPayload(String) - Method in class com.netflix.dyno.queues.Message

setPriority(int) - Method in class com.netflix.dyno.queues.Message

Sets the message priority.

setTimeout(long) - Method in class com.netflix.dyno.queues.Message

setTimeout(long, TimeUnit) - Method in class com.netflix.dyno.queues.Message

Helper method for the Message.setTimeout(long)

setUnackTimeout(String, long) - Method in interface com.netflix.dyno.queues.DynoQueue

Sets the unack timeout on the message (changes the default timeout to the new value).

setUnackTimeout(String, long) - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

shardSizes() - Method in interface com.netflix.dyno.queues.DynoQueue

shardSizes() - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

ShardSupplier - Interface in com.netflix.dyno.queues

size() - Method in interface com.netflix.dyno.queues.DynoQueue

size() - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

T

toString() - Method in class com.netflix.dyno.queues.Message

W

withNonQuorumConn(JedisCommands) - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

withQuorumConn(JedisCommands) - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

withUnackSchedulerTime(int) - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

withUnackTime(int) - Method in class com.netflix.dyno.queues.redis.RedisDynoQueue

A C D E G H M P Q R S T W