TimeoutCountSequenceSizeReleaseStrategy (Spring Integration 5.5.11 API)

java.lang.Object

org.springframework.integration.aggregator.TimeoutCountSequenceSizeReleaseStrategy

All Implemented Interfaces:: ReleaseStrategy

public class TimeoutCountSequenceSizeReleaseStrategy
extends Object
implements ReleaseStrategy

A ReleaseStrategy that releases all messages if any of the following is true:

The sequence is complete (if there is one).
There are more messages than a threshold set by the user.
The time elapsed since the earliest message, according to their timestamps, if present, exceeds a timeout set by the user.

Since:: 2.0
Author:: Dave Syer, Gary Russell, Peter Uhlenbruck

Field Summary

Fields

Modifier and Type Field Description

static int DEFAULT_THRESHOLD
Default threshold is effectively infinite.

static long DEFAULT_TIMEOUT
Default timeout is one minute.
Constructor Summary

Constructors

Constructor Description

TimeoutCountSequenceSizeReleaseStrategy()

TimeoutCountSequenceSizeReleaseStrategy(int threshold, long timeout)
Method Summary

Modifier and Type Method Description

boolean canRelease(MessageGroup messages)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- DEFAULT_TIMEOUT
  
  public static final long DEFAULT_TIMEOUT
  
  Default timeout is one minute.
  
  See Also:
  
  Constant Field Values
- DEFAULT_THRESHOLD
  
  public static final int DEFAULT_THRESHOLD
  
  Default threshold is effectively infinite.
  
  See Also:
  
  Constant Field Values
Constructor Details
- TimeoutCountSequenceSizeReleaseStrategy
  
  public TimeoutCountSequenceSizeReleaseStrategy()
- TimeoutCountSequenceSizeReleaseStrategy
  
  public TimeoutCountSequenceSizeReleaseStrategy(int threshold, long timeout)
  
  Parameters:
  
  threshold - the number of messages to accept before releasing
  
  timeout - the timeout for the release in milliseconds
Method Details
- canRelease
  
  public boolean canRelease(MessageGroup messages)
  
  Specified by:
  
  canRelease in interface ReleaseStrategy