reactor.event.routing

Class ConsumerFilteringEventRouter

java.lang.Object

reactor.event.routing.ConsumerFilteringEventRouter

All Implemented Interfaces:

EventRouter

public class ConsumerFilteringEventRouter
extends java.lang.Object
implements EventRouter

An EventRouter that filters consumers before routing events to them.

Constructor Summary

Constructors

Constructor and Description
ConsumerFilteringEventRouter(Filter filter, ConsumerInvoker consumerInvoker) Creates a new ConsumerFilteringEventRouter that will use the filter to filter consumers.

Method Summary

Modifier and Type	Method and Description
ConsumerInvoker	getConsumerInvoker() Returns the ConsumerInvoker being used by the event router
Filter	getFilter() Returns the Filter being used
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.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerFilteringEventRouter

public ConsumerFilteringEventRouter(Filter filter,
                                    ConsumerInvoker consumerInvoker)

Creates a new ConsumerFilteringEventRouter that will use the filter to filter consumers.

Parameters:

filter - The filter to use. Must not be null.

consumerInvoker - Used to invoke consumers. Must not be null.

Throws:

java.lang.IllegalArgumentException - if filter or consumerInvoker is null.

Method Detail

route

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

Description copied from interface: EventRouter

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.

Specified by:

route in interface EventRouter

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

getFilter

public Filter getFilter()

Returns the Filter being used

Returns:

The Filter.

getConsumerInvoker

public ConsumerInvoker getConsumerInvoker()

Returns the ConsumerInvoker being used by the event router

Returns:

The ConsumerInvoker.