org.hobbit.core.rabbit.consume

Class AbstractMessageConsumer

java.lang.Object

com.rabbitmq.client.DefaultConsumer

org.hobbit.core.rabbit.consume.AbstractMessageConsumer

All Implemented Interfaces:

com.rabbitmq.client.Consumer, Closeable, AutoCloseable, MessageConsumer

Direct Known Subclasses:

MessageConsumerImpl, PairedConsumerImpl

public abstract class AbstractMessageConsumer
extends com.rabbitmq.client.DefaultConsumer
implements MessageConsumer

Field Summary

Fields

Modifier and Type	Field and Description
protected com.rabbitmq.client.Channel	channel The channel of the queue from which the incoming messages will be consumed.
private Semaphore	currentlyProcessedMessages Semaphore used to control the number of messages that can be processed in parallel.
static int	DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES Default value of the maxParallelProcessedMsgs attribute.
private static org.slf4j.Logger	LOGGER
private int	maxParallelProcessedMsgs The maximum number of incoming messages that are processed in parallel.
protected String	name
protected DataReceiver	receiver The DataReceiver which is using this consumer.

Constructor Summary

Constructors

Constructor and Description
AbstractMessageConsumer(DataReceiver receiver, com.rabbitmq.client.Channel channel, int maxParallelProcessedMsgs, String name)

Method Summary

Modifier and Type	Method and Description
void	finishProcessing()
abstract int	getOpenStreamCount()
void	handleDelivery(String consumerTag, com.rabbitmq.client.Envelope envelope, com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body)
protected abstract boolean	handleMessage(com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body)
void	waitForTermination()

Methods inherited from class com.rabbitmq.client.DefaultConsumer

getChannel, getConsumerTag, handleCancel, handleCancelOk, handleConsumeOk, handleRecoverOk, handleShutdownSignal

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.rabbitmq.client.Consumer

handleCancel, handleCancelOk, handleConsumeOk, handleRecoverOk, handleShutdownSignal

Methods inherited from interface java.io.Closeable

close

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES

public static final int DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES

Default value of the maxParallelProcessedMsgs attribute.

See Also:

Constant Field Values

maxParallelProcessedMsgs

private final int maxParallelProcessedMsgs

The maximum number of incoming messages that are processed in parallel. Additional messages have to wait.

currentlyProcessedMessages

private Semaphore currentlyProcessedMessages

Semaphore used to control the number of messages that can be processed in parallel.

receiver

protected DataReceiver receiver

The DataReceiver which is using this consumer.

channel

protected com.rabbitmq.client.Channel channel

The channel of the queue from which the incoming messages will be consumed.

name

protected String name

Constructor Detail

AbstractMessageConsumer

public AbstractMessageConsumer(DataReceiver receiver,
                               com.rabbitmq.client.Channel channel,
                               int maxParallelProcessedMsgs,
                               String name)

Method Detail

handleDelivery

public void handleDelivery(String consumerTag,
                           com.rabbitmq.client.Envelope envelope,
                           com.rabbitmq.client.AMQP.BasicProperties properties,
                           byte[] body)
                    throws IOException

Specified by:

handleDelivery in interface com.rabbitmq.client.Consumer

Overrides:

handleDelivery in class com.rabbitmq.client.DefaultConsumer

Throws:

IOException

handleMessage

protected abstract boolean handleMessage(com.rabbitmq.client.AMQP.BasicProperties properties,
                                         byte[] body)
                                  throws IOException

Throws:

IOException

finishProcessing

public void finishProcessing()
                      throws InterruptedException

Specified by:

finishProcessing in interface MessageConsumer

Throws:

InterruptedException

getOpenStreamCount

public abstract int getOpenStreamCount()

Specified by:

getOpenStreamCount in interface MessageConsumer

waitForTermination

public void waitForTermination()

Specified by:

waitForTermination in interface MessageConsumer