Package org.apache.curator.framework.recipes.queue

Interface QueueConsumer<T>

All Superinterfaces:

ConnectionStateListener

All Known Implementing Classes:

BlockingQueueConsumer

public interface QueueConsumer<T>
extends ConnectionStateListener

Message Consumer

Method Summary

Modifier and Type	Method	Description
void	consumeMessage(T message)	Process a message from the queue

Methods inherited from interface org.apache.curator.framework.state.ConnectionStateListener

doNotProxy, stateChanged

Method Details

consumeMessage

void consumeMessage(T message)
             throws Exception

Process a message from the queue

Parameters:

message - message to process

Throws:

Exception - any errors