org.axonframework.commandhandling.model

Class ForwardMatchingInstances<T extends Message<?>>

java.lang.Object

org.axonframework.commandhandling.model.ForwardMatchingInstances<T>

Type Parameters:

T - the implementation T of the Message being filtered.

All Implemented Interfaces:

ForwardingMode<T>

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

Only forward messages of type T if the routing key of the message matches that of the entity. Essentially, this means that events are only forwarded if the Message mentions the identifier of the entity instance.

Constructor Summary

Constructors

Constructor and Description
ForwardMatchingInstances()

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.
void	initialize(Field field, EntityModel childEntity) Initializes an instance of a ForwardingMode.

Methods inherited from class java.lang.Object

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

Constructor Detail

ForwardMatchingInstances

public ForwardMatchingInstances()

Method Detail

initialize

public void initialize(Field field,
                       EntityModel childEntity)

Description copied from interface: ForwardingMode

Initializes an instance of a ForwardingMode.

Specified by:

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

Parameters:

field - The Field to apply a ForwardingMode on. Provided to be able to check for annotations attributes which might assist in the forwarding process.

childEntity - A EntityModel constructed from the given field.

filterCandidates

public <E> Stream<E> filterCandidates(T message,
                                      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.