org.rarefiedredis.reliable

Class RedisReliableConsumer<T>

java.lang.Object

org.rarefiedredis.reliable.RedisReliableConsumer<T>

public final class RedisReliableConsumer<T>
extends Object

Constructor Summary

Constructors

Constructor and Description
RedisReliableConsumer(org.rarefiedredis.redis.IRedisClient client, IRedisReliableMover<T> imover, IRedisReliableDeleter<T> ideleter)

Method Summary

Modifier and Type	Method and Description
T	ack(String key, String inprocesskey, T element)
T	consume(String key, String inprocesskey)
T	consume(String key, String inprocesskey, T element)
T	fail(String key, String inprocesskey, T element)
static RedisReliableConsumer<String>	ListConsumer(org.rarefiedredis.redis.IRedisClient client)
static RedisReliableConsumer<String>	SetConsumer(org.rarefiedredis.redis.IRedisClient client)
static RedisReliableConsumer<String>	StringConsumer(org.rarefiedredis.redis.IRedisClient client)

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisReliableConsumer

public RedisReliableConsumer(org.rarefiedredis.redis.IRedisClient client,
                             IRedisReliableMover<T> imover,
                             IRedisReliableDeleter<T> ideleter)

Method Detail

consume

public T consume(String key,
                 String inprocesskey)
          throws org.rarefiedredis.redis.WrongTypeException

Throws:

org.rarefiedredis.redis.WrongTypeException

consume

public T consume(String key,
                 String inprocesskey,
                 T element)
          throws org.rarefiedredis.redis.WrongTypeException

Throws:

org.rarefiedredis.redis.WrongTypeException

ack

public T ack(String key,
             String inprocesskey,
             T element)
      throws org.rarefiedredis.redis.WrongTypeException

Throws:

org.rarefiedredis.redis.WrongTypeException

fail

public T fail(String key,
              String inprocesskey,
              T element)
       throws org.rarefiedredis.redis.WrongTypeException

Throws:

org.rarefiedredis.redis.WrongTypeException

StringConsumer

public static RedisReliableConsumer<String> StringConsumer(org.rarefiedredis.redis.IRedisClient client)

ListConsumer

public static RedisReliableConsumer<String> ListConsumer(org.rarefiedredis.redis.IRedisClient client)

SetConsumer

public static RedisReliableConsumer<String> SetConsumer(org.rarefiedredis.redis.IRedisClient client)