reactor.event.routing

Interface EventRouter

All Known Implementing Classes:

ConsumerFilteringEventRouter, TraceableDelegatingEventRouter

public interface EventRouter

An EventRouter is used to route an Event to Consumers.

Method Summary

Modifier and Type	Method and Description
void	route(java.lang.Object key, Event<?> event, java.util.List<Registration<? extends Consumer<? extends Event<?>>>> consumers, Consumer<?> completionConsumer, Consumer<java.lang.Throwable> errorConsumer) Routes the event, triggered by a notification with the given key to the consumers.

Method Detail

route

void route(java.lang.Object key,
           Event<?> event,
           java.util.List<Registration<? extends Consumer<? extends Event<?>>>> consumers,
           Consumer<?> completionConsumer,
           Consumer<java.lang.Throwable> errorConsumer)

Routes the event, triggered by a notification with the given key to the consumers. Depending on the router implementation, zero or more of the consumers will receive the event. Upon successful completion of the event routing, the completionConsumer will be invoked. completionConsumer may be null. In the event of an exception during routing the errorConsumer is invoked. errorConsumer may be null, in which case the exception is swallowed.

Parameters:

key - The notification key

event - The Event to route

consumers - The Consumers to route the event to.

completionConsumer - The Consumer to invoke upon successful completion of event routing

errorConsumer - The Consumer to invoke when an error occurs during event routing