org.dice_research.ldcbench.rabbit

Class FanoutExchangeConsumer

java.lang.Object

org.dice_research.ldcbench.rabbit.FanoutExchangeConsumer

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

ObjectStreamFanoutExchangeConsumer

public class FanoutExchangeConsumer
extends Object
implements Closeable

This class implements consuming of byte array data from messages coming through fanout exchange.

Field Summary

Fields

Modifier and Type	Field and Description
private com.rabbitmq.client.Channel	channel

Constructor Summary

Constructors

Constructor and Description
FanoutExchangeConsumer(org.hobbit.core.rabbit.RabbitQueueFactory queueFactory, String exchangeName) Initializes consuming of messages coming through specified exchange.

Method Summary

Modifier and Type	Method and Description
void	close()
void	handle(byte[] body) Abstract method which is called when a message is received.

Methods inherited from class java.lang.Object

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

Field Detail

channel

private com.rabbitmq.client.Channel channel

Constructor Detail

FanoutExchangeConsumer

public FanoutExchangeConsumer(org.hobbit.core.rabbit.RabbitQueueFactory queueFactory,
                              String exchangeName)
                       throws IOException

Initializes consuming of messages coming through specified exchange.

Parameters:

queueFactory - factory to create queues with

exchangeName - name of the exchange

Throws:

IOException

Method Detail

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

handle

public void handle(byte[] body)

Abstract method which is called when a message is received.

Parameters:

body - message body as a byte array