org.threadly.concurrent

Interface BlockingQueueConsumer.ConsumerAcceptor<T>

Type Parameters:

T - Type of item this acceptor will receive

Enclosing class:

BlockingQueueConsumer<T>

public static interface BlockingQueueConsumer.ConsumerAcceptor<T>

Interface for an implementation which can accept consumed tasks. You must provide an implementation of this interface on construction of the BlockingQueueConsumer.

Since:

1.0.0

Method Summary

Modifier and Type	Method and Description
void	acceptConsumedItem(T item) Called when ever the queue consumer has removed an item from the queue.

Method Detail

acceptConsumedItem

void acceptConsumedItem(T item)
                 throws java.lang.Exception

Called when ever the queue consumer has removed an item from the queue. This call should block until the acceptor is ready for another item.

Parameters:

item - Object that was removed from the queue

Throws:

java.lang.Exception - possible exception that could be thrown