com.consol.citrus.message

Class DefaultMessageCorrelator

java.lang.Object

com.consol.citrus.message.DefaultMessageCorrelator

All Implemented Interfaces:

MessageCorrelator

public class DefaultMessageCorrelator
extends Object
implements MessageCorrelator

Default message correlator implementation using the Spring integration message id as correlation key.

Author:

Christoph Deppisch

Constructor Summary

Constructors

Constructor and Description
DefaultMessageCorrelator()

Method Summary

Modifier and Type	Method and Description
String	getCorrelationKey(Message request) Constructs the correlation key from the message header.
String	getCorrelationKey(String id) Get the correlation header name.
String	getCorrelationKeyName(String consumerName) Constructs unique correlation key name for given consumer name.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultMessageCorrelator

public DefaultMessageCorrelator()

Method Detail

getCorrelationKey

public String getCorrelationKey(Message request)

Description copied from interface: MessageCorrelator

Constructs the correlation key from the message header.

Specified by:

getCorrelationKey in interface MessageCorrelator

Returns:

getCorrelationKey

public String getCorrelationKey(String id)

Description copied from interface: MessageCorrelator

Get the correlation header name.

Specified by:

getCorrelationKey in interface MessageCorrelator

Returns:

getCorrelationKeyName

public String getCorrelationKeyName(String consumerName)

Description copied from interface: MessageCorrelator

Constructs unique correlation key name for given consumer name. Correlation key must be unique across all message consumers running inside a test case. Therefore consumer name is passed as argument and must be part of the constructed correlation key name.

Specified by:

getCorrelationKeyName in interface MessageCorrelator

Returns: