Package org.citrusframework.message.correlation

Class PollingCorrelationManager<T>

java.lang.Object
org.citrusframework.message.correlation.DefaultCorrelationManager<T>
org.citrusframework.message.correlation.PollingCorrelationManager<T>
All Implemented Interfaces:
org.citrusframework.message.correlation.CorrelationManager<T>
public class PollingCorrelationManager<T> extends DefaultCorrelationManager<T>
Extension of default correlation manager adds polling mechanism for find operation on object store. In case object is not found in store retry is automatically performed. Polling interval and overall retry timeout is usually defined in endpoint configuration.
Since:
2.1

  • Constructor Details

    • PollingCorrelationManager

      public PollingCorrelationManager(org.citrusframework.endpoint.PollableEndpointConfiguration endpointConfiguration, String retryLogMessage)
      Constructor using fields.
      Parameters:
      endpointConfiguration -
      retryLogMessage -

  • Method Details

    • find

      public T find(String correlationKey)
      Convenience method for using default timeout settings of endpoint configuration.
      Parameters:
      correlationKey -
      Returns:

    • getCorrelationKey

      public String getCorrelationKey(String correlationKeyName, org.citrusframework.context.TestContext context)
      Specified by:
      getCorrelationKey in interface org.citrusframework.message.correlation.CorrelationManager<T>
      Overrides:
      getCorrelationKey in class DefaultCorrelationManager<T>

    • find

      public T find(String correlationKey, long timeout)
      Specified by:
      find in interface org.citrusframework.message.correlation.CorrelationManager<T>
      Overrides:
      find in class DefaultCorrelationManager<T>

    • getRetryLogMessage

      public String getRetryLogMessage()
      Gets the retry logger message
      Returns: