org.hobbit.core.rabbit.consume

Class QueueingConsumerBasedImpl

java.lang.Object

com.rabbitmq.client.DefaultConsumer

com.rabbitmq.client.QueueingConsumer

org.hobbit.core.rabbit.consume.QueueingConsumerBasedImpl

All Implemented Interfaces:

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

public class QueueingConsumerBasedImpl
extends com.rabbitmq.client.QueueingConsumer
implements MessageConsumer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	QueueingConsumerBasedImpl.Builder
protected class	QueueingConsumerBasedImpl.MsgReceivingTask

Nested classes/interfaces inherited from class com.rabbitmq.client.QueueingConsumer

com.rabbitmq.client.QueueingConsumer.Delivery

Field Summary

Fields

Modifier and Type	Field and Description
private int	errorCount
private ExecutorService	executor
private static org.slf4j.Logger	LOGGER
private static int	MAX_MESSAGE_BUFFER_SIZE
private String	name
private boolean	oldFormatWarningPrinted
protected RabbitQueue	queue
protected DataReceiver	receiver The DataReceiver which is using this consumer.
private TerminatableRunnable	receiverTask
private Thread	receiverThread
protected Map<String,DataReceiveState>	streamStats

Constructor Summary

Constructors

Constructor and Description
QueueingConsumerBasedImpl(DataReceiver receiver, RabbitQueue queue, int maxParallelProcessedMsgs)
QueueingConsumerBasedImpl(DataReceiver receiver, RabbitQueue queue, int maxParallelProcessedMsgs, String name)

Method Summary

Modifier and Type	Method and Description
static QueueingConsumerBasedImpl.Builder	builder()
protected TerminatableRunnable	buildMsgReceivingTask(com.rabbitmq.client.QueueingConsumer consumer) This factory method creates a runnable task that uses the given consumer to receive incoming messages.
void	close()
void	finishProcessing()
int	getErrorCount()
int	getOpenStreamCount()
protected boolean	handleMessage(com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body)
protected boolean	handleSimpleMessage(byte[] body)
void	increaseErrorCount()
protected void	processMessageData(byte[] messageData, DataReceiveState state)
void	waitForTermination()

Methods inherited from class com.rabbitmq.client.QueueingConsumer

handleCancel, handleDelivery, handleShutdownSignal, nextDelivery, nextDelivery

Methods inherited from class com.rabbitmq.client.DefaultConsumer

getChannel, getConsumerTag, handleCancelOk, handleConsumeOk, handleRecoverOk

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, handleDelivery, handleRecoverOk, handleShutdownSignal

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

MAX_MESSAGE_BUFFER_SIZE

private static final int MAX_MESSAGE_BUFFER_SIZE

See Also:

Constant Field Values

receiver

protected DataReceiver receiver

The DataReceiver which is using this consumer.

executor

private ExecutorService executor

streamStats

protected Map<String,DataReceiveState> streamStats

queue

protected RabbitQueue queue

errorCount

private int errorCount

receiverTask

private TerminatableRunnable receiverTask

receiverThread

private Thread receiverThread

oldFormatWarningPrinted

private boolean oldFormatWarningPrinted

name

private String name

Constructor Detail

QueueingConsumerBasedImpl

public QueueingConsumerBasedImpl(DataReceiver receiver,
                                 RabbitQueue queue,
                                 int maxParallelProcessedMsgs)

QueueingConsumerBasedImpl

public QueueingConsumerBasedImpl(DataReceiver receiver,
                                 RabbitQueue queue,
                                 int maxParallelProcessedMsgs,
                                 String name)

Method Detail

handleMessage

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

Throws:

IOException

handleSimpleMessage

protected boolean handleSimpleMessage(byte[] body)
                               throws IOException

Parameters:

properties -

body -

Returns:

Throws:

IOException

processMessageData

protected void processMessageData(byte[] messageData,
                                  DataReceiveState state)

getOpenStreamCount

public int getOpenStreamCount()

Specified by:

getOpenStreamCount in interface MessageConsumer

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

waitForTermination

public void waitForTermination()

Specified by:

waitForTermination in interface MessageConsumer

finishProcessing

public void finishProcessing()
                      throws InterruptedException

Specified by:

finishProcessing in interface MessageConsumer

Throws:

InterruptedException

increaseErrorCount

public void increaseErrorCount()

getErrorCount

public int getErrorCount()

buildMsgReceivingTask

protected TerminatableRunnable buildMsgReceivingTask(com.rabbitmq.client.QueueingConsumer consumer)

This factory method creates a runnable task that uses the given consumer to receive incoming messages.

Parameters:

consumer - the consumer that can be used to receive messages

Returns:

a Runnable instance that will handle incoming messages as soon as it will be executed

builder

public static QueueingConsumerBasedImpl.Builder builder()