org.hobbit.core.rabbit.consume

Class MessageConsumerImpl

java.lang.Object

com.rabbitmq.client.DefaultConsumer

org.hobbit.core.rabbit.consume.AbstractMessageConsumer

org.hobbit.core.rabbit.consume.MessageConsumerImpl

All Implemented Interfaces:

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

Deprecated.

Has major problems receiving all the submitted data. Use QueueingConsumerBasedImpl instead.

@Deprecated
public class MessageConsumerImpl
extends AbstractMessageConsumer

Author:

Michael Röder (michael.roeder@uni-paderborn.de)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MessageConsumerImpl.Builder Deprecated.

Field Summary

Fields

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

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

channel, name, receiver

Constructor Summary

Constructors

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

Method Summary

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

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

Deprecated.

MAX_MESSAGE_BUFFER_SIZE

private static final int MAX_MESSAGE_BUFFER_SIZE

Deprecated.

See Also:

Constant Field Values

DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES

protected static final int DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES

Deprecated.

Default value of the AbstractMessageConsumer.maxParallelProcessedMsgs attribute.

See Also:

Constant Field Values

executor

private ExecutorService executor

Deprecated.

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

streamStats

protected Map<String,DataReceiveState> streamStats

Deprecated.

oldFormatWarningPrinted

private boolean oldFormatWarningPrinted

Deprecated.

Constructor Detail

MessageConsumerImpl

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

Deprecated.

MessageConsumerImpl

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

Deprecated.

Method Detail

handleMessage

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

Deprecated.

Specified by:

handleMessage in class AbstractMessageConsumer

Throws:

IOException

handleSimpleMessage

protected boolean handleSimpleMessage(byte[] body)
                               throws IOException

Deprecated.

Parameters:

properties -

body -

Returns:

Throws:

IOException

processMessageData

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

Deprecated.

getOpenStreamCount

public int getOpenStreamCount()

Deprecated.

Specified by:

getOpenStreamCount in interface MessageConsumer

Specified by:

getOpenStreamCount in class AbstractMessageConsumer

close

public void close()
           throws IOException

Deprecated.

Throws:

IOException

waitForTermination

public void waitForTermination()

Deprecated.

Specified by:

waitForTermination in interface MessageConsumer

Overrides:

waitForTermination in class AbstractMessageConsumer

builder

public static MessageConsumerImpl.Builder builder()

Deprecated.