Package it.tidalwave.messagebus.spi

Class SimpleAsyncMessageDelivery

java.lang.Object

it.tidalwave.messagebus.spi.SimpleAsyncMessageDelivery

All Implemented Interfaces:

MessageDelivery

public class SimpleAsyncMessageDelivery
extends java.lang.Object
implements MessageDelivery

An implementation of MessageDelivery that dispatches messages as they are delivered, each one in a separated thread.

Since:

2.2

Author:

Fabrizio Giudici

Constructor Summary

Constructors

Constructor	Description
SimpleAsyncMessageDelivery()

Method Summary

Modifier and Type	Method	Description
<TOPIC> void	deliverMessage(java.lang.Class<TOPIC> topic, TOPIC 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 Detail

SimpleAsyncMessageDelivery

public SimpleAsyncMessageDelivery()

Method Detail

initialize

public void initialize(@Nonnull
                       SimpleMessageBus messageBusSupport)

Description copied from interface: MessageDelivery

Initializes this object.

Specified by:

initialize in interface MessageDelivery

Parameters:

messageBusSupport - the message bus

deliverMessage

public <TOPIC> void deliverMessage(@Nonnull
                                   java.lang.Class<TOPIC> topic,
                                   @Nonnull
                                   TOPIC message)

Description copied from interface: MessageDelivery

Delivers a message.

Specified by:

deliverMessage in interface MessageDelivery

Type Parameters:

TOPIC - the static type of the topic

Parameters:

topic - the dynamic type of the topic

message - the message