Package org.flowable.eventregistry.model

Class KafkaInboundChannelModel.RetryConfiguration

java.lang.Object
org.flowable.eventregistry.model.KafkaInboundChannelModel.RetryConfiguration
Enclosing class:
KafkaInboundChannelModel
public static class KafkaInboundChannelModel.RetryConfiguration extends Object

  • Field Details

    • attempts

      protected String attempts

    • dltTopicSuffix

      protected String dltTopicSuffix

    • retryTopicSuffix

      protected String retryTopicSuffix

    • fixedDelayTopicStrategy

      protected String fixedDelayTopicStrategy

    • topicSuffixingStrategy

      protected String topicSuffixingStrategy

    • nonBlockingBackOff

      protected KafkaInboundChannelModel.NonBlockingRetryBackOff nonBlockingBackOff

    • autoCreateTopics

      protected String autoCreateTopics

    • numPartitions

      protected String numPartitions

    • replicationFactor

      protected String replicationFactor

  • Constructor Details

    • RetryConfiguration

      public RetryConfiguration()

  • Method Details

    • getAttempts

      public String getAttempts()

    • setAttempts

      public void setAttempts(String attempts)

    • getDltTopicSuffix

      public String getDltTopicSuffix()

    • setDltTopicSuffix

      public void setDltTopicSuffix(String dltTopicSuffix)

    • getRetryTopicSuffix

      public String getRetryTopicSuffix()

    • setRetryTopicSuffix

      public void setRetryTopicSuffix(String retryTopicSuffix)

    • getFixedDelayTopicStrategy

      public String getFixedDelayTopicStrategy()

    • setFixedDelayTopicStrategy

      public void setFixedDelayTopicStrategy(String fixedDelayTopicStrategy)

    • getTopicSuffixingStrategy

      public String getTopicSuffixingStrategy()

    • setTopicSuffixingStrategy

      public void setTopicSuffixingStrategy(String topicSuffixingStrategy)

    • getNonBlockingBackOff

      public KafkaInboundChannelModel.NonBlockingRetryBackOff getNonBlockingBackOff()

    • setNonBlockingBackOff

      public void setNonBlockingBackOff(KafkaInboundChannelModel.NonBlockingRetryBackOff nonBlockingBackOff)

    • getAutoCreateTopics

      public String getAutoCreateTopics()

    • setAutoCreateTopics

      public void setAutoCreateTopics(String autoCreateTopics)

    • getNumPartitions

      public String getNumPartitions()

    • setNumPartitions

      public void setNumPartitions(String numPartitions)

    • getReplicationFactor

      public String getReplicationFactor()

    • setReplicationFactor

      public void setReplicationFactor(String replicationFactor)