A B C D E F G H I L M N O P Q R S W

A

AbstractMessageHandler<T,R> - Class in com.blacklocus.qs

This class provides boring default implementations for the MessageHandler interface.

AbstractMessageHandler() - Constructor for class com.blacklocus.qs.AbstractMessageHandler

AbstractQueueItemHandler<Q,T,R> - Class in com.blacklocus.qs

AbstractQueueItemHandler() - Constructor for class com.blacklocus.qs.AbstractQueueItemHandler

B

BatchingQuIP<T> - Class in com.blacklocus.qs

Decorator around any QueueItemProvider that batches entries together.

BatchingQuIP(QueueItemProvider<T>, Integer) - Constructor for class com.blacklocus.qs.BatchingQuIP

C

close() - Method in class com.blacklocus.qs.ExternalQueueItemProvider

close() - Method in class com.blacklocus.qs.LineReaderQuIP

com.blacklocus.misc - package com.blacklocus.misc

com.blacklocus.qs - package com.blacklocus.qs

convert(Q) - Method in interface com.blacklocus.qs.QueueItemHandler

Convert the given queue item on the queue item processing thread.

D

DEFAULT_SLEEP_MS - Static variable in class com.blacklocus.qs.QueueReader

default sleep time in ms between idle queue reads

delete(Message) - Method in interface com.blacklocus.qs.MessageProvider

Delete the given message.

E

ExceptingRunnable - Class in com.blacklocus.misc

ExceptingRunnable() - Constructor for class com.blacklocus.misc.ExceptingRunnable

executor - Variable in class com.blacklocus.qs.QueueReader

ExternalQueueItemProvider<Q> - Class in com.blacklocus.qs

ExternalQueueItemProvider() - Constructor for class com.blacklocus.qs.ExternalQueueItemProvider

ExternalQueueItemProvider(Long, TimeUnit) - Constructor for class com.blacklocus.qs.ExternalQueueItemProvider

ExternalQueueItemProvider(BlockingQueue<Q>, Long, TimeUnit) - Constructor for class com.blacklocus.qs.ExternalQueueItemProvider

F

filtered(MessageProvider, Predicate<Message>) - Static method in class com.blacklocus.qs.MessageProviders

Filters the values returned by QueueItemProvider.next() by some filter.

G

getAttributes() - Method in interface com.blacklocus.qs.Message

Return the message attributes as a map.

getBody() - Method in interface com.blacklocus.qs.Message

Return the message body content.

getId() - Method in interface com.blacklocus.qs.Message

Return the unique identifier for this message.

getReceipt() - Method in interface com.blacklocus.qs.Message

Return the unique message receipt used to signal an instance of this message was received and can be acknowledged or deleted.

go() - Method in class com.blacklocus.misc.ExceptingRunnable

go() - Method in class com.blacklocus.qs.QueueReader

H

handler - Variable in class com.blacklocus.qs.QueueReader

hasNext() - Method in class com.blacklocus.qs.BatchingQuIP

hasNext() - Method in class com.blacklocus.qs.ExternalQueueItemProvider

hasNext() - Method in class com.blacklocus.qs.LineReaderQuIP

hasNext() - Method in class com.blacklocus.qs.OneAtATimeQueueItemProvider

hasNext() - Method in interface com.blacklocus.qs.QueueItemProvider

hasNext() - Method in class com.blacklocus.qs.RestartingQueueItemProvider

I

InfiniteRunnable - Class in com.blacklocus.misc

InfiniteRunnable(Runnable) - Constructor for class com.blacklocus.misc.InfiniteRunnable

iterator() - Method in class com.blacklocus.qs.BatchingQuIP

iterator() - Method in class com.blacklocus.qs.ExternalQueueItemProvider

iterator() - Method in class com.blacklocus.qs.LineReaderQuIP

iterator() - Method in class com.blacklocus.qs.OneAtATimeQueueItemProvider

iterator() - Method in interface com.blacklocus.qs.QueueItemProvider

Generally returns this.

iterator() - Method in class com.blacklocus.qs.RestartingQueueItemProvider

L

LineReaderQuIP - Class in com.blacklocus.qs

QueueItemProvider based on lines of text from an InputStream.

LineReaderQuIP(InputStream, Integer) - Constructor for class com.blacklocus.qs.LineReaderQuIP

M

Message - Interface in com.blacklocus.qs

This is a simple message abstraction.

MessageHandler<T,R> - Interface in com.blacklocus.qs

Implementations of this class perform message conversion, processing, error handling and hand off of a message retrieved from a queue.

MessageProvider - Interface in com.blacklocus.qs

Implementations of this interface provide a mechanism for retrieving messages.

MessageProviders - Class in com.blacklocus.qs

Provide some common functionality to wrap around existing MessageProvider implementations.

MessageProviders() - Constructor for class com.blacklocus.qs.MessageProviders

MessageProviders.NextCallback - Interface in com.blacklocus.qs

MessageQueueReader<T,R> - Class in com.blacklocus.qs

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.

MessageQueueReader(MessageProvider, MessageHandler<T, R>, ExecutorService) - Constructor for class com.blacklocus.qs.MessageQueueReader

Construct a new MessageQueueReader with the default idle timeout.

MessageQueueReader(MessageProvider, MessageHandler<T, R>, ExecutorService, long) - Constructor for class com.blacklocus.qs.MessageQueueReader

Construct a new MessageQueueReader with the given timeout.

N

newDefaultMessageProvider(MessageProvider, long) - Static method in class com.blacklocus.qs.MessageProviders

Chain together a safe and an empty message return tracking MessageProvider.

newDefaultMessageProvider(MessageProvider, long, int) - Static method in class com.blacklocus.qs.MessageProviders

Chain together a safe and an empty message return tracking MessageProvider.

newInfiniteLoggingRunnable(Runnable) - Static method in class com.blacklocus.misc.Runnables

newLoggingRunnable(Runnable) - Static method in class com.blacklocus.misc.Runnables

newSafeMessageProvider(MessageProvider) - Static method in class com.blacklocus.qs.MessageProviders

Wrap each call of the given MessageProvider with a try/catch such that they always return correctly without throwing an Exception.

newUntilNextEmptyMessageProvider(MessageProvider, long) - Static method in class com.blacklocus.qs.MessageProviders

Wrap an existing MessageProvider such that after a specified number of calls to next() that results in 0 messages being returned, hasNext() flips over to return false.

newUntilNextEmptyOrMaximumMessageProvider(MessageProvider, long, int) - Static method in class com.blacklocus.qs.MessageProviders

Wrap an existing MessageProvider such that after a specified number of calls to next() that results in 0 messages being returned, or the maximum limit of messages is reached, hasNext() flips over to return false.

newUntilSlowOrMaximumMessageProvider(MessageProvider, long, int, int) - Static method in class com.blacklocus.qs.MessageProviders

Like MessageProviders.newUntilNextEmptyOrMaximumMessageProvider(MessageProvider, long, int) but instead of detecting numerous "empties" considers numerous "slows", where that is defined to be calls to next that produce less than the specified batch threshold.

next() - Method in class com.blacklocus.qs.BatchingQuIP

next() - Method in class com.blacklocus.qs.ExternalQueueItemProvider

next() - Method in class com.blacklocus.qs.LineReaderQuIP

next(Collection<Message>) - Method in interface com.blacklocus.qs.MessageProviders.NextCallback

next() - Method in class com.blacklocus.qs.OneAtATimeQueueItemProvider

next() - Method in interface com.blacklocus.qs.QueueItemProvider

next() - Method in class com.blacklocus.qs.RestartingQueueItemProvider

O

onComplete(Q, T, R) - Method in class com.blacklocus.qs.AbstractQueueItemHandler

onComplete(Q, T, R) - Method in interface com.blacklocus.qs.QueueItemHandler

Called whether the processing results in success or failure on the queue item processing thread.

OneAtATimeQueueItemProvider<Q> - Class in com.blacklocus.qs

A simple QueueItemProvider which accepts any iterator and provides messages one at a time to a QueueReader.

OneAtATimeQueueItemProvider(Iterator<Q>) - Constructor for class com.blacklocus.qs.OneAtATimeQueueItemProvider

onError(Q, T, Throwable) - Method in class com.blacklocus.qs.AbstractQueueItemHandler

onError(Q, T, Throwable) - Method in interface com.blacklocus.qs.QueueItemHandler

Called when an Exception occurs while processing the given queue item on the queue item processing thread.

onSuccess(Q, T, R) - Method in class com.blacklocus.qs.AbstractQueueItemHandler

onSuccess(Q, T, R) - Method in interface com.blacklocus.qs.QueueItemHandler

Called when processing completes successfully on the queue item processing thread.

P

process(T) - Method in interface com.blacklocus.qs.QueueItemHandler

Return the result of processing a queue item of the given converted type on the queue item processing thread.

put(Q) - Method in class com.blacklocus.qs.ExternalQueueItemProvider

Q

QueueItemHandler<Q,T,R> - Interface in com.blacklocus.qs

More generalized form of MessageHandler

QueueItemProvider<Q> - Interface in com.blacklocus.qs

The superest class inside of the com.blacklocus.qs namespace which can provide items to a QueueReader.

queueItemProvider - Variable in class com.blacklocus.qs.QueueReader

QueueReader<Q,T,R> - Class in com.blacklocus.qs

A more generalized version of the MessageQueueReader

QueueReader(Iterable<Collection<Q>>, QueueItemHandler<Q, T, R>, ExecutorService) - Constructor for class com.blacklocus.qs.QueueReader

Construct a new MessageQueueReader with the default idle timeout.

QueueReader(Iterable<Collection<Q>>, QueueItemHandler<Q, T, R>, ExecutorService, long) - Constructor for class com.blacklocus.qs.QueueReader

Construct a new MessageQueueReader with the given timeout.

R

remove() - Method in class com.blacklocus.qs.BatchingQuIP

remove() - Method in class com.blacklocus.qs.ExternalQueueItemProvider

remove() - Method in class com.blacklocus.qs.LineReaderQuIP

remove() - Method in class com.blacklocus.qs.OneAtATimeQueueItemProvider

remove() - Method in interface com.blacklocus.qs.QueueItemProvider

A means to delete the message because it is done or should not be processed again.

remove() - Method in class com.blacklocus.qs.RestartingQueueItemProvider

RestartingQueueItemProvider<Q> - Class in com.blacklocus.qs

RestartingQueueItemProvider(long, Supplier<QueueItemProvider<Q>>) - Constructor for class com.blacklocus.qs.RestartingQueueItemProvider

run() - Method in class com.blacklocus.misc.ExceptingRunnable

run() - Method in class com.blacklocus.misc.InfiniteRunnable

Runnables - Class in com.blacklocus.misc

Runnables() - Constructor for class com.blacklocus.misc.Runnables

S

scanningCallback(MessageProvider, MessageProviders.NextCallback) - Static method in class com.blacklocus.qs.MessageProviders

Applies an arbitrary callback to the results of calls to QueueItemProvider.next() before bubbling onward.

setVisibilityTimeout(Message, Integer) - Method in interface com.blacklocus.qs.MessageProvider

Sets the specified message's visibility timeout.

sleepMs - Variable in class com.blacklocus.qs.QueueReader

W

withFuture(Q, Future<Pair<Q, R>>) - Method in class com.blacklocus.qs.AbstractQueueItemHandler

withFuture(Q, Future<Pair<Q, R>>) - Method in interface com.blacklocus.qs.QueueItemHandler

Called after the queue item is retrieved off of the queue and handed off to an Executor for processing.

A B C D E F G H I L M N O P Q R S W