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 Summary

Fields

Modifier and Type	Field and Description
protected String	attempts
protected String	autoCreateTopics
protected String	dltTopicSuffix
protected String	fixedDelayTopicStrategy
protected KafkaInboundChannelModel.NonBlockingRetryBackOff	nonBlockingBackOff
protected String	numPartitions
protected String	replicationFactor
protected String	retryTopicSuffix
protected String	topicSuffixingStrategy

Constructor Summary

Constructors

Constructor and Description
RetryConfiguration()

Method Summary

Modifier and Type	Method and Description
String	getAttempts()
String	getAutoCreateTopics()
String	getDltTopicSuffix()
String	getFixedDelayTopicStrategy()
KafkaInboundChannelModel.NonBlockingRetryBackOff	getNonBlockingBackOff()
String	getNumPartitions()
String	getReplicationFactor()
String	getRetryTopicSuffix()
String	getTopicSuffixingStrategy()
void	setAttempts(String attempts)
void	setAutoCreateTopics(String autoCreateTopics)
void	setDltTopicSuffix(String dltTopicSuffix)
void	setFixedDelayTopicStrategy(String fixedDelayTopicStrategy)
void	setNonBlockingBackOff(KafkaInboundChannelModel.NonBlockingRetryBackOff nonBlockingBackOff)
void	setNumPartitions(String numPartitions)
void	setReplicationFactor(String replicationFactor)
void	setRetryTopicSuffix(String retryTopicSuffix)
void	setTopicSuffixingStrategy(String topicSuffixingStrategy)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

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 Detail

RetryConfiguration

public RetryConfiguration()

Method Detail

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)