org.hobbit.core.rabbit.paired

Class PairedConsumerImpl

java.lang.Object

com.rabbitmq.client.DefaultConsumer

org.hobbit.core.rabbit.consume.AbstractMessageConsumer

org.hobbit.core.rabbit.paired.PairedConsumerImpl

All Implemented Interfaces:

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

public class PairedConsumerImpl
extends AbstractMessageConsumer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PairedConsumerImpl.Builder

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES Default value of the AbstractMessageConsumer.maxParallelProcessedMsgs attribute.
private ExecutorService	executor Semaphore used to control the number of messages that can be processed in parallel.
private static org.slf4j.Logger	LOGGER
private static int	MAX_MESSAGE_BUFFER_SIZE
protected Map<String,DataReceiveState>	streamStats

Fields inherited from class org.hobbit.core.rabbit.consume.AbstractMessageConsumer

channel, name, receiver

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
static PairedConsumerImpl.Builder	builder()
void	close()
int	getOpenStreamCount()
protected boolean	handleMessage(com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body)
protected void	processMessageData(byte[] messageData, DataReceiveState state)
private String[]	readStreamIds(byte[] body)
void	waitForTermination()

Methods inherited from class org.hobbit.core.rabbit.consume.AbstractMessageConsumer

finishProcessing, handleDelivery

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

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

DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES

protected static final int DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES

Default value of the AbstractMessageConsumer.maxParallelProcessedMsgs attribute.

See Also:

Constant Field Values

executor

private ExecutorService executor

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

streamStats

protected Map<String,DataReceiveState> streamStats

Constructor Detail

PairedConsumerImpl

public PairedConsumerImpl(DataReceiver receiver,
                          com.rabbitmq.client.Channel channel,
                          int maxParallelProcessedMsgs)

PairedConsumerImpl

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

Method Detail

handleMessage

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

Specified by:

handleMessage in class AbstractMessageConsumer

Throws:

IOException

readStreamIds

private String[] readStreamIds(byte[] body)
                        throws Exception

Throws:

Exception

processMessageData

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

getOpenStreamCount

public int getOpenStreamCount()

Specified by:

getOpenStreamCount in interface MessageConsumer

Specified by:

getOpenStreamCount in class AbstractMessageConsumer

close

public void close()
           throws IOException

Throws:

IOException

waitForTermination

public void waitForTermination()

Specified by:

waitForTermination in interface MessageConsumer

Overrides:

waitForTermination in class AbstractMessageConsumer

builder

public static PairedConsumerImpl.Builder builder()