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 Summary

Constructors

Constructor	Description
HeaderAttributeCorrelationStrategy(String attributeName)

Method Summary

Modifier and Type	Method	Description
Object	getCorrelationKey(Message<?> message)	Find the correlation key for the given message.

Methods inherited from class java.lang.Object

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

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.