public interface QueueConsumer<T> extends ConnectionStateListener
Modifier and Type | Method and Description |
---|---|
void |
consumeMessage(T message)
Process a message from the queue
|
stateChanged
void consumeMessage(T message) throws java.lang.Exception
message
- message to processjava.lang.Exception
- any errors