Package org.springframework.integration.aggregator

Class HeaderAttributeCorrelationStrategy

java.lang.Object
org.springframework.integration.aggregator.HeaderAttributeCorrelationStrategy
All Implemented Interfaces:
CorrelationStrategy
public class HeaderAttributeCorrelationStrategy extends Object implements CorrelationStrategy
Default implementation of CorrelationStrategy. Uses a provided header attribute to determine the correlation key value.
Author:
Marius Bogoevici, Artem Bilan

  • Constructor Details

    • HeaderAttributeCorrelationStrategy

      public HeaderAttributeCorrelationStrategy(String attributeName)

  • Method Details

    • getCorrelationKey

      public Object getCorrelationKey(Message<?> message)
      Description copied from interface: CorrelationStrategy
      Find the correlation key for the given message. If no key can be determined the strategy should not return null, but throw an exception.
      Specified by:
      getCorrelationKey in interface CorrelationStrategy
      Parameters:
      message - The message.
      Returns:
      The correlation key.