ai.grakn.redisq.consumer

Class RedisqConsumer<T extends Document>

java.lang.Object

ai.grakn.redisq.consumer.RedisqConsumer<T>

Type Parameters:

T -

All Implemented Interfaces:

QueueConsumer<T>

public class RedisqConsumer<T extends Document>
extends Object
implements QueueConsumer<T>

TODO: docs

Constructor Summary

Constructors

Constructor and Description
RedisqConsumer(java.util.function.Consumer<T> consumer, redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool, Redisq<T> tRedisq) TODO: docs

Method Summary

Modifier and Type	Method and Description
void	process(T element) This method implements the logic for consuming documents from the queue.

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisqConsumer

public RedisqConsumer(java.util.function.Consumer<T> consumer,
                      redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool,
                      Redisq<T> tRedisq)

TODO: docs

Parameters:

consumer -

jedisPool -

tRedisq -

Method Detail

process

public void process(T element)

Description copied from interface: QueueConsumer

This method implements the logic for consuming documents from the queue. The result is not returned but some effect should be produced.

Specified by:

process in interface QueueConsumer<T extends Document>

Parameters:

element - Document read from the queue