Package 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	Description
ForwardToAll()

Method Summary

Modifier and Type	Method	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 Details

ForwardToAll

public ForwardToAll()

Method Details

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.