org.axonframework.correlation
Class SimpleCorrelationDataProvider

java.lang.Object
  org.axonframework.correlation.SimpleCorrelationDataProvider

All Implemented Interfaces:

CorrelationDataProvider<Message>

public class SimpleCorrelationDataProvider
extends Object
implements CorrelationDataProvider<Message>

CorrelationDataProvider implementation defines correlation headers by the header names. The headers from messages with these keys are returned as correlation data.

Since:

2.3

Author:

Allard Buijze

Constructor Summary

SimpleCorrelationDataProvider(String... metaDataKeys)
Initializes the CorrelationDataProvider to return the meta data of messages with given metaDataKeys as correlation data.

Method Summary

Map<String,?>

correlationDataFor(Message message) Provides a map with the entries to attach as correlation data to generated messages while processing given message.

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleCorrelationDataProvider

public SimpleCorrelationDataProvider(String... metaDataKeys)

Initializes the CorrelationDataProvider to return the meta data of messages with given metaDataKeys as correlation data.

Parameters:

metaDataKeys - The keys of the meta data entries from messages to return as correlation data

Method Detail

correlationDataFor

public Map<String,?> correlationDataFor(Message message)

Description copied from interface: CorrelationDataProvider

Provides a map with the entries to attach as correlation data to generated messages while processing given message.

This method should not return null.

Specified by:

correlationDataFor in interface CorrelationDataProvider<Message>

Parameters:

message - The message to define correlation data for

Returns:

the data to attach as correlation data to generated messages