eu.bandm.tools.message

Class MessageTee<M extends Message>

java.lang.Object

eu.bandm.tools.message.MessageTee<M>

All Implemented Interfaces:

MessageReceiver<M>

public class MessageTee<M extends Message>
extends Object
implements MessageReceiver<M>

Re-sends the message received sequeentially to a multitude of current drains.

For details see receive(Message).

Field Summary

Fields

Modifier and Type	Field and Description
protected List<MessageReceiver<? super M>>	drains

Constructor Summary

Constructors

Constructor and Description
MessageTee()
MessageTee(MessageReceiver<? super M>... drains) Internally calls add(MessageReceiver), please cf.!
MessageTee(MessageReceiver<? super M> drain1) Nonvararg specialization avoids unchecked warnings.
MessageTee(MessageReceiver<? super M> drain1, MessageReceiver<? super M> drain2) Nonvararg specialization avoids unchecked warnings Internally calls add(MessageReceiver), please cf.!
MessageTee(MessageReceiver<? super M> drain1, MessageReceiver<? super M> drain2, MessageReceiver<? super M> drain3) Nonvararg specialization avoids unchecked warnings.

Method Summary

Modifier and Type	Method and Description
void	add(MessageReceiver<? super M>... newdrains) Internally calls add(MessageReceiver), please cf.!
void	add(MessageReceiver<? super M> drain) Adds the message receiver at the end of the list of all current drains.
void	add(MessageReceiver<? super M> drain1, MessageReceiver<? super M> drain2) Nonvararg specialization avoids unchecked warnings.
void	addAll(Iterable<MessageReceiver<? super M>> newdrains) Internally calls add(MessageReceiver), please cf.!
void	clear()
List<MessageReceiver<? super M>>	getDrains()
void	receive(M message) Propagates the message received sequentially to a multitude of current drains. If there is one or ore MessageThrowers in the pipeline behind these drains, then additionally the message is thrown after all drains have been sent to. (Any other Throwable is, of course, not intercepted!)

Methods inherited from class java.lang.Object

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

Field Detail

drains

protected final List<MessageReceiver<? super M extends Message>> drains

Constructor Detail

MessageTee

public MessageTee()

MessageTee

public MessageTee(MessageReceiver<? super M>... drains)

Internally calls add(MessageReceiver), please cf.!

MessageTee

public MessageTee(MessageReceiver<? super M> drain1)

Nonvararg specialization avoids unchecked warnings. Internally calls add(MessageReceiver), please cf.!

MessageTee

public MessageTee(MessageReceiver<? super M> drain1,
                  MessageReceiver<? super M> drain2)

Nonvararg specialization avoids unchecked warnings Internally calls add(MessageReceiver), please cf.!

MessageTee

public MessageTee(MessageReceiver<? super M> drain1,
                  MessageReceiver<? super M> drain2,
                  MessageReceiver<? super M> drain3)

Nonvararg specialization avoids unchecked warnings. Internally calls add(MessageReceiver), please cf.!

Method Detail

getDrains

public List<MessageReceiver<? super M>> getDrains()

add

public void add(MessageReceiver<? super M> drain)

Adds the message receiver at the end of the list of all current drains. Cf receive(Message). If it is already contained at some position in the list, it ia first removed and then re-inserted at the end of the list.

add

public void add(MessageReceiver<? super M> drain1,
                MessageReceiver<? super M> drain2)

Nonvararg specialization avoids unchecked warnings. Internally calls add(MessageReceiver), please cf.!

add

public void add(MessageReceiver<? super M>... newdrains)

Internally calls add(MessageReceiver), please cf.!

addAll

public void addAll(Iterable<MessageReceiver<? super M>> newdrains)

Internally calls add(MessageReceiver), please cf.!

clear

public void clear()

receive

public void receive(M message)

Propagates the message received sequentially to a multitude of current drains.

If there is one or ore MessageThrowers in the pipeline behind these drains, then additionally the message is thrown after all drains have been sent to.
(Any other Throwable is, of course, not intercepted!)

Specified by:

receive in interface MessageReceiver<M extends Message>