org.springframework.integration.aop.SimpleActiveIdleReceiveMessageAdvice

All Implemented Interfaces:: Advice, Interceptor, MethodInterceptor, ReceiveMessageAdvice

public class SimpleActiveIdleReceiveMessageAdvice
extends Object
implements ReceiveMessageAdvice

A simple advice that polls at one rate when messages exist and another when there are no messages.

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.
`void`	`setActivePollPeriod(long activePollPeriod)`	Set the poll period when messages are returned.
`void`	`setIdlePollPeriod(long idlePollPeriod)`	Set the poll period when messages are not returned.

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

beforeReceive, invoke

Constructor Details
- SimpleActiveIdleReceiveMessageAdvice
  
  public SimpleActiveIdleReceiveMessageAdvice(DynamicPeriodicTrigger trigger)
Method Details
- setIdlePollPeriod
  
  public void setIdlePollPeriod(long idlePollPeriod)
  
  Set the poll period when messages are not returned. Defaults to the trigger's period.
  
  Parameters:
  
  idlePollPeriod - the period in milliseconds.
- setActivePollPeriod
  
  public void setActivePollPeriod(long activePollPeriod)
  
  Set the poll period when messages are returned. Defaults to the trigger's period.
  
  Parameters:
  
  activePollPeriod - the period in milliseconds.
- afterReceive
  
  public Message<?> afterReceive(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 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.

Class SimpleActiveIdleReceiveMessageAdvice