Class ConsumerPolicyBuilder

java.lang.Object
org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicyBuilder
Direct Known Subclasses:
DocumentConsumerPolicyBuilder

public class ConsumerPolicyBuilder extends Object
Since:
9.2
  • Field Details

    • batchPolicy

      protected BatchPolicy batchPolicy
    • retryPolicy

      protected net.jodah.failsafe.RetryPolicy<Object> retryPolicy
    • skipFailure

      protected boolean skipFailure
    • waitMessageTimeout

      protected Duration waitMessageTimeout
    • startOffset

      protected ConsumerPolicy.StartOffset startOffset
    • salted

      protected boolean salted
    • name

      protected String name
    • maxThreads

      protected short maxThreads
  • Constructor Details

    • ConsumerPolicyBuilder

      protected ConsumerPolicyBuilder()
  • Method Details