| Interface | Description |
|---|---|
| Message |
This is a simple message abstraction.
|
| MessageHandler<T,R> |
Implementations of this class perform message conversion, processing, error
handling and hand off of a message retrieved from a queue.
|
| MessageProvider |
Implementations of this interface provide a mechanism for retrieving
messages.
|
| MessageProviders.NextCallback | |
| QueueItemHandler<Q,T,R> |
More generalized form of
MessageHandler |
| QueueItemProvider<Q> |
The superest class inside of the com.blacklocus.qs namespace which can provide items to a
QueueReader. |
| Class | Description |
|---|---|
| AbstractMessageHandler<T,R> |
This class provides boring default implementations for the MessageHandler
interface.
|
| AbstractQueueItemHandler<Q,T,R> | |
| BatchingQuIP<T> |
Decorator around any
QueueItemProvider that batches entries together. |
| ExternalQueueItemProvider<Q> | |
| LineReaderQuIP |
QueueItemProvider based on lines of text from an InputStream. |
| MessageProviders |
Provide some common functionality to wrap around existing
MessageProvider implementations. |
| MessageQueueReader<T,R> |
This class provides a general purpose "grab thing off queue and process it
with threads" abstraction, decoupling the queue reading thread from the pool
of processing threads.
|
| OneAtATimeQueueItemProvider<Q> |
A simple
QueueItemProvider which accepts any iterator and provides messages one at a time to a
QueueReader. |
| QueueReader<Q,T,R> |
A more generalized version of the
MessageQueueReader |
| RestartingQueueItemProvider<Q> |