Package org.citrusframework.message

Class DefaultMessageCorrelator

java.lang.Object
org.citrusframework.message.DefaultMessageCorrelator
All Implemented Interfaces:
org.citrusframework.message.MessageCorrelator
public class DefaultMessageCorrelator extends Object implements org.citrusframework.message.MessageCorrelator
Default message correlator implementation using the Citrus message id as correlation key.

  • Constructor Details

    • DefaultMessageCorrelator

      public DefaultMessageCorrelator()

  • Method Details

    • getCorrelationKey

      public String getCorrelationKey(org.citrusframework.message.Message request)
      Specified by:
      getCorrelationKey in interface org.citrusframework.message.MessageCorrelator

    • getCorrelationKey

      public String getCorrelationKey(String id)
      Specified by:
      getCorrelationKey in interface org.citrusframework.message.MessageCorrelator

    • getCorrelationKeyName

      public String getCorrelationKeyName(String consumerName)
      Specified by:
      getCorrelationKeyName in interface org.citrusframework.message.MessageCorrelator