Package it.tidalwave.messagebus.spi

Class RoundRobinAsyncMessageDelivery

java.lang.Object

it.tidalwave.messagebus.spi.RoundRobinAsyncMessageDelivery

All Implemented Interfaces:

MessageDelivery

public class RoundRobinAsyncMessageDelivery
extends Object
implements MessageDelivery

An implementation of MessageDelivery that dispatches messages in a round-robin fashion, topic by topic. Each delivery is performed in a separated thread.

Since:

2.2

Author:

Fabrizio Giudici

Constructor Summary

Constructors

Constructor	Description
RoundRobinAsyncMessageDelivery()

Method Summary

Modifier and Type	Method	Description
<T> void	deliverMessage(Class<T> topic, T message)	Delivers a message.
void	initialize(SimpleMessageBus messageBusSupport)	Initializes this object.

Methods inherited from class java.lang.Object

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

Constructor Details

RoundRobinAsyncMessageDelivery

public RoundRobinAsyncMessageDelivery()

Method Details

initialize

public void initialize(@Nonnull
 SimpleMessageBus messageBusSupport)

Initializes this object.

Specified by:

initialize in interface MessageDelivery

Parameters:

messageBusSupport - the message bus

deliverMessage

public <T> void deliverMessage(@Nonnull
 Class<T> topic,
 @Nonnull
 T message)

Delivers a message.

Specified by:

deliverMessage in interface MessageDelivery

Type Parameters:

T - the static type of the topic

Parameters:

topic - the dynamic type of the topic

message - the message