Provides classes to support message publication using AOP.
MessageSourceMutatorthat uses a
CompoundTriggerto adjust the poller - when a message is present, the compound trigger's primary trigger is used to determine the next poll.A
MethodInterceptorthat publishes Messages to a channel.A
ReceiveMessageAdviceextension that can mutate a
MessageSourcebefore and/or after
PublisherMetadataSourceimplementation that retrieves the channel name and expression strings from an annotation.An advisor that will apply the
MessagePublishingInterceptorto any methods containing the provided annotations.Post-processes beans that contain the method-level @
Publisherannotation.An AOP advice to perform hooks before and/or after a
receive()contract is called.A simple advice that polls at one rate when messages exist and another when there are no messages.Simple implementation of
PublisherMetadataSourcethat allows for configuration of a single channel name, payload expression, and array of header key=value expressions.