org.axonframework.modelling.command

Class ForwardToAll<T extends Message<?>>

java.lang.Object

org.axonframework.modelling.command.ForwardToAll<T>

Type Parameters:

T - the implementation T of the Message being filtered.

All Implemented Interfaces:

ForwardingMode<T>

public class ForwardToAll<T extends Message<?>>
extends Object
implements ForwardingMode<T>

Forward all messages T regardless of their set up.

Since:

3.1

Author:

Steven van Beelen

Constructor Summary

Constructors

Constructor and Description
ForwardToAll()

Method Summary

Modifier and Type	Method and Description
<E> Stream<E>	filterCandidates(T message, Stream<E> candidates) Filter the given Stream of candidates which are to handle the supplied message.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.modelling.command.ForwardingMode

initialize

Constructor Detail

ForwardToAll

public ForwardToAll()

Method Detail

filterCandidates

public <E> Stream<E> filterCandidates(@Nonnull
                                      T message,
                                      @Nonnull
                                      Stream<E> candidates)

Description copied from interface: ForwardingMode

Filter the given Stream of candidates which are to handle the supplied message.

Specified by:

filterCandidates in interface ForwardingMode<T extends Message<?>>

Type Parameters:

E - The type of the candidates

Parameters:

message - The message of type T to be forwarded.

candidates - The Stream of candidates to filter.

Returns:

a filtered Stream of candidates which will handle the message.