com.blacklocus.qs

Class QueueReader<Q,T,R>

java.lang.Object

com.blacklocus.misc.ExceptingRunnable

com.blacklocus.qs.QueueReader<Q,T,R>

Type Parameters:

Q - queue item type

T - the type of queue item that this reader can convert

R - the result of processing the converted message

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

MessageQueueReader

public class QueueReader<Q,T,R>
extends ExceptingRunnable

A more generalized version of the MessageQueueReader

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_SLEEP_MS default sleep time in ms between idle queue reads
protected java.util.concurrent.ExecutorService	executor
protected QueueItemHandler<Q,T,R>	handler
protected java.lang.Iterable<java.util.Collection<Q>>	queueItemProvider
protected long	sleepMs

Constructor Summary

Constructors

Constructor and Description
QueueReader(java.lang.Iterable<java.util.Collection<Q>> provider, QueueItemHandler<Q,T,R> handler, java.util.concurrent.ExecutorService executor) Construct a new MessageQueueReader with the default idle timeout.
QueueReader(java.lang.Iterable<java.util.Collection<Q>> provider, QueueItemHandler<Q,T,R> handler, java.util.concurrent.ExecutorService executor, long sleepMs) Construct a new MessageQueueReader with the given timeout.

Method Summary

Modifier and Type	Method and Description
void	go()

Methods inherited from class com.blacklocus.misc.ExceptingRunnable

run

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_SLEEP_MS

public static final long DEFAULT_SLEEP_MS

default sleep time in ms between idle queue reads

See Also:

Constant Field Values

queueItemProvider

protected java.lang.Iterable<java.util.Collection<Q>> queueItemProvider

handler

protected QueueItemHandler<Q,T,R> handler

executor

protected java.util.concurrent.ExecutorService executor

sleepMs

protected long sleepMs

Constructor Detail

QueueReader

public QueueReader(java.lang.Iterable<java.util.Collection<Q>> provider,
                   QueueItemHandler<Q,T,R> handler,
                   java.util.concurrent.ExecutorService executor)

Construct a new MessageQueueReader with the default idle timeout.

Parameters:

provider - provider to endlessly pull messages from

handler - handler implementation to convert and process messages

executor - executor service used for forking message handler processing

QueueReader

public QueueReader(java.lang.Iterable<java.util.Collection<Q>> provider,
                   QueueItemHandler<Q,T,R> handler,
                   java.util.concurrent.ExecutorService executor,
                   long sleepMs)

Construct a new MessageQueueReader with the given timeout.

Parameters:

provider - provider to endlessly pull messages from

handler - handler implementation to convert and process messages

executor - executor service used for forking message handler processing

sleepMs - how long to sleep in ms between reads from the queue where no messages are returned

Method Detail

go

public void go()
        throws java.lang.Exception

Specified by:

go in class ExceptingRunnable

Throws:

java.lang.Exception