org.hobbit.core.rabbit.consume

Interface MessageConsumer

All Superinterfaces:

AutoCloseable, Closeable, com.rabbitmq.client.Consumer

All Known Implementing Classes:

AbstractMessageConsumer, MessageConsumerImpl, PairedConsumerImpl, QueueingConsumerBasedImpl

public interface MessageConsumer
extends com.rabbitmq.client.Consumer, Closeable

Method Summary

Modifier and Type	Method and Description
void	finishProcessing()
int	getOpenStreamCount()
void	waitForTermination()

Methods inherited from interface com.rabbitmq.client.Consumer

handleCancel, handleCancelOk, handleConsumeOk, handleDelivery, handleRecoverOk, handleShutdownSignal

Methods inherited from interface java.io.Closeable

close

Method Detail

finishProcessing

void finishProcessing()
               throws InterruptedException

Throws:

InterruptedException

getOpenStreamCount

int getOpenStreamCount()

waitForTermination

void waitForTermination()