Package org.springframework.integration.aop

Class CompoundTriggerAdvice

java.lang.Object

org.springframework.integration.aop.CompoundTriggerAdvice

All Implemented Interfaces:

Advice, Interceptor, MethodInterceptor, MessageSourceMutator, ReceiveMessageAdvice

public class CompoundTriggerAdvice
extends Object
implements MessageSourceMutator, ReceiveMessageAdvice

A MessageSourceMutator that uses a CompoundTrigger to adjust the poller - when a message is present, the compound trigger's primary trigger is used to determine the next poll. When no message is present, the override trigger is used.

The poller advised by this class must be configured to use the same CompoundTrigger instance and must not use a task executor.

Since:

4.3

Author:

Gary Russell, Artem Bilan

Constructor Summary

Constructors

Constructor	Description
CompoundTriggerAdvice(CompoundTrigger compoundTrigger, Trigger overrideTrigger)

Method Summary

Modifier and Type	Method	Description
Message<?>	afterReceive(Message<?> result, Object source)	Subclasses can take actions based on the result of the Joinpoint.proceed(); e.g.
Message<?>	afterReceive(Message<?> result, MessageSource<?> source)	Deprecated. since 5.3 in favor of afterReceive(Message, Object)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.aop.MessageSourceMutator

beforeReceive, beforeReceive

Methods inherited from interface org.springframework.integration.aop.ReceiveMessageAdvice

invoke

Constructor Details

CompoundTriggerAdvice

public CompoundTriggerAdvice(CompoundTrigger compoundTrigger, Trigger overrideTrigger)

Method Details

afterReceive

@Deprecated public Message<?> afterReceive(Message<?> result, MessageSource<?> source)

Deprecated.

since 5.3 in favor of afterReceive(Message, Object)

Description copied from interface: MessageSourceMutator

Subclasses can take actions based on the result of the poll; e.g. adjust the trigger. The message can also be replaced with a new one.

Specified by:

afterReceive in interface MessageSourceMutator

Parameters:

result - the received message.

source - the message source.

Returns:

the message or null

afterReceive

@Nullable public Message<?> afterReceive(@Nullable Message<?> result, Object source)

Description copied from interface: ReceiveMessageAdvice

Subclasses can take actions based on the result of the Joinpoint.proceed(); e.g. adjust the trigger. The message can also be replaced with a new one.

Specified by:

afterReceive in interface MessageSourceMutator

Specified by:

afterReceive in interface ReceiveMessageAdvice

Parameters:

result - the received message.

source - the source of the message to receive.

Returns:

a message to continue to process the result, null to discard whatever the Joinpoint.proceed() returned.