org.dice_research.ldcbench.rabbit

Class ObjectStreamFanoutExchangeConsumer<T>

java.lang.Object

org.dice_research.ldcbench.rabbit.FanoutExchangeConsumer

org.dice_research.ldcbench.rabbit.ObjectStreamFanoutExchangeConsumer<T>

All Implemented Interfaces:

Closeable, AutoCloseable

public class ObjectStreamFanoutExchangeConsumer<T>
extends FanoutExchangeConsumer

This class implements consuming of Serializable object from messages coming through fanout exchange.

Constructor Summary

Constructors

Constructor and Description
ObjectStreamFanoutExchangeConsumer(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	handle(byte[] body) Abstract method which is called when a message is received.
void	handle(T object) Abstract method which is called when a message is received.

Methods inherited from class org.dice_research.ldcbench.rabbit.FanoutExchangeConsumer

close

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectStreamFanoutExchangeConsumer

public ObjectStreamFanoutExchangeConsumer(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

handle

public final void handle(byte[] body)

Description copied from class: FanoutExchangeConsumer

Abstract method which is called when a message is received.

Overrides:

handle in class FanoutExchangeConsumer

Parameters:

body - message body as a byte array

handle

public void handle(T object)

Abstract method which is called when a message is received.

Parameters:

object - message body as an object