Package org.axonframework.messaging.correlation

Class MultiCorrelationDataProvider<T extends Message>

java.lang.Object
org.axonframework.messaging.correlation.MultiCorrelationDataProvider<T>
All Implemented Interfaces:
CorrelationDataProvider
public class MultiCorrelationDataProvider<T extends Message> extends Object implements CorrelationDataProvider
CorrelationDataProvider that combines the data of multiple other correlation providers. When multiple instance provide the same keys, a delegate will override the entries provided by previously resolved delegates.
Since:
2.3
Author:
Allard Buijze

  • Constructor Details

    • MultiCorrelationDataProvider

      public MultiCorrelationDataProvider(List<? extends CorrelationDataProvider> correlationDataProviders)
      Initialize the correlation data provider, delegating to given correlationDataProviders.
      Parameters:
      correlationDataProviders - the providers to delegate to.

  • Method Details

    • 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. Any exception thrown from this method might interfere with rolling back a transaction. Therefore, by default exceptions are caught, ignoring the correlation data that should have been added.

      Specified by:
      correlationDataFor in interface CorrelationDataProvider
      Parameters:
      message - The message to define correlation data for
      Returns:
      the data to attach as correlation data to generated messages