org.springframework.integration.aop

Class AbstractMessageSourceAdvice

java.lang.Object

org.springframework.integration.aop.AbstractMessageSourceAdvice

All Implemented Interfaces:

org.aopalliance.aop.Advice, org.aopalliance.intercept.Interceptor, org.aopalliance.intercept.MethodInterceptor

Direct Known Subclasses:

CompoundTriggerAdvice, SimpleActiveIdleMessageSourceAdvice

public abstract class AbstractMessageSourceAdvice
extends java.lang.Object
implements org.aopalliance.intercept.MethodInterceptor

Advice for a MessageSource.receive() method to decide whether a poll should be ignored and/or take action after the receive.

Since:

4.2

Author:

Gary Russell

Constructor Summary

Constructors

Constructor and Description
AbstractMessageSourceAdvice()

Method Summary

Modifier and Type	Method and Description
abstract org.springframework.messaging.Message<?>	afterReceive(org.springframework.messaging.Message<?> result, MessageSource<?> source) Subclasses can take actions based on the result of the poll; e.g.
abstract boolean	beforeReceive(MessageSource<?> source) Subclasses can decide whether to proceed with this poll.
java.lang.Object	invoke(org.aopalliance.intercept.MethodInvocation invocation)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractMessageSourceAdvice

public AbstractMessageSourceAdvice()

Method Detail

invoke

public final java.lang.Object invoke(org.aopalliance.intercept.MethodInvocation invocation)
                              throws java.lang.Throwable

Specified by:

invoke in interface org.aopalliance.intercept.MethodInterceptor

Throws:

java.lang.Throwable

beforeReceive

public abstract boolean beforeReceive(MessageSource<?> source)

Subclasses can decide whether to proceed with this poll.

Parameters:

source - the message source.

Returns:

true to proceed.

afterReceive

public abstract org.springframework.messaging.Message<?> afterReceive(org.springframework.messaging.Message<?> result,
                                                                      MessageSource<?> source)

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.

Parameters:

result - the received message.

source - the message source.

Returns:

a message to continue to process the result, null to discard whatever the poll returned.