@FunctionalInterface public interface MessageSourceMutator
MessageSource
before and/or after
MessageSource.receive()
is called.Modifier and Type | Method and Description |
---|---|
Message<?> |
afterReceive(Message<?> result,
MessageSource<?> source)
Subclasses can take actions based on the result of the poll; e.g.
|
default boolean |
beforeReceive(MessageSource<?> source)
Subclasses can decide whether to proceed with this poll.
|
default boolean beforeReceive(MessageSource<?> source)
source
- the message source.Message<?> afterReceive(Message<?> result, MessageSource<?> source)
trigger
. The message can also be replaced with a new one.result
- the received message.source
- the message source.