net.grinder.communication

Class MessageDispatchSender

java.lang.Object

net.grinder.communication.MessageDispatchSender

All Implemented Interfaces:

MessageDispatchRegistry, Sender

public final class MessageDispatchSender
extends Object
implements Sender, MessageDispatchRegistry

Passive Senderclass that dispatches incoming messages to the appropriate handler.

Author:

Philip Aston

Nested Class Summary

Nested classes/interfaces inherited from interface net.grinder.communication.MessageDispatchRegistry

MessageDispatchRegistry.AbstractBlockingHandler<T extends Message>, MessageDispatchRegistry.AbstractHandler<T extends Message>, MessageDispatchRegistry.BlockingHandler<T extends Message>, MessageDispatchRegistry.Handler<T extends Message>

Constructor Summary

Constructors

Constructor and Description
MessageDispatchSender()

Method Summary

Methods

Modifier and Type	Method and Description
void	addFallback(MessageDispatchRegistry.Handler<Message> messageHandler) Register a message handler that is called if no other handler or responder is registered for the message type.
void	send(Message message) Sends a message to each handler until one claims to have handled the message.
<T extends Message,S extends T> MessageDispatchRegistry.BlockingHandler<T>	set(Class<S> messageType, MessageDispatchRegistry.BlockingHandler<T> responder) Register a message responder.
<T extends Message,S extends T> MessageDispatchRegistry.Handler<T>	set(Class<S> messageType, MessageDispatchRegistry.Handler<T> messageHandler) Register a message handler.
void	shutdown() Shutdown all our handlers.

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageDispatchSender

public MessageDispatchSender()

Method Detail

set

public <T extends Message,S extends T> MessageDispatchRegistry.Handler<T> set(Class<S> messageType,
                                                                     MessageDispatchRegistry.Handler<T> messageHandler)

Register a message handler.

Specified by:

set in interface MessageDispatchRegistry

Type Parameters:

T - Constrains messageHandler to be able to handle messageType.

S - Class of messageType.

Parameters:

messageType - Messages of this type will be routed to the handler.

messageHandler - The message handler.

Returns:

The previous message handler registered for messageType or null.

set

public <T extends Message,S extends T> MessageDispatchRegistry.BlockingHandler<T> set(Class<S> messageType,
                                                                             MessageDispatchRegistry.BlockingHandler<T> responder)

Register a message responder.

Specified by:

set in interface MessageDispatchRegistry

Type Parameters:

T - Constrains messageHandler to be able to handle messageType.

S - Class of messageType.

Parameters:

messageType - Messages of this type will be routed to the handler.

responder - The message responder.

Returns:

The previous message handler registered for messageType or null.

addFallback

public void addFallback(MessageDispatchRegistry.Handler<Message> messageHandler)

Register a message handler that is called if no other handler or responder is registered for the message type.

Specified by:

addFallback in interface MessageDispatchRegistry

Parameters:

messageHandler - The sender.

send

public void send(Message message)
          throws CommunicationException

Sends a message to each handler until one claims to have handled the message.

Specified by:

send in interface Sender

Parameters:

message - The message.

Throws:

CommunicationException - If one of the handlers failed.

shutdown

public void shutdown()

Shutdown all our handlers.

Specified by:

shutdown in interface Sender