eu.bandm.tools.message

Class SingleSender<M extends Message>

java.lang.Object

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

Direct Known Subclasses:

LocationMap.Translator, MessageAsync, MessageCatcher, MessageKindFilter, MessageLocationFilter, MessageMapper, MessagePasser, MessageStripExceptions, MessageSync, MuLiMessageReceiver, SimpleMessage.Generator

public abstract class SingleSender<M extends Message>
extends Object

Common superclass of all which send messages to one single drain.

This includes some "genuine message sources", ie. senders only, but most of the subclasses are MessageReceivers, which pass on the received messages to one single drain.

This drain can be enquired and set, ie. it can change dynamically during execution. Intentionally, the code will crash if a receiver==null and a send is attempted

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
SingleSender() After calling this constructor, a call to setReceiver(MessageReceiver) is necessary before you can use send(Message).
SingleSender(MessageReceiver<? super M> r)

Method Summary

Modifier and Type	Method and Description
MessageReceiver<? super M>	getReceiver()
protected void	send(M m) Used to pass on a message to the current receiver.
void	setReceiver(MessageReceiver<? super M> r)

Methods inherited from class java.lang.Object

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

Field Detail

receiver

protected MessageReceiver<? super M extends Message> receiver

Constructor Detail

SingleSender

public SingleSender()

After calling this constructor, a call to setReceiver(MessageReceiver) is necessary before you can use send(Message). Otherwise code will crash intentionally.

SingleSender

public SingleSender(MessageReceiver<? super M> r)

Method Detail

setReceiver

public void setReceiver(MessageReceiver<? super M> r)

getReceiver

public MessageReceiver<? super M> getReceiver()

send

protected void send(M m)

Used to pass on a message to the current receiver.
Intentionally, the code will crash if this is ==null