Package com.aim2be.platform.outbox.redis
Class RedisOutboxProperties.Poller
java.lang.Object
com.aim2be.platform.outbox.redis.RedisOutboxProperties.Poller
- Enclosing class:
- RedisOutboxProperties
Cold-path poller + single-writer lock configuration (refinements #4 + #5).
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionlonglongintlonglonglongintlongbooleanvoidsetBackoffBaseMs(long backoffBaseMs) voidsetBackoffMaxMs(long backoffMaxMs) voidsetBatchSize(int batchSize) voidsetEnabled(boolean enabled) voidsetIntervalMs(long intervalMs) voidsetLockRenewMarginMs(long lockRenewMarginMs) voidsetLockTtlMs(long lockTtlMs) voidsetMaxRetries(int maxRetries) voidsetSendTimeoutMs(long sendTimeoutMs)
-
Constructor Details
-
Poller
public Poller()
-
-
Method Details
-
isEnabled
public boolean isEnabled() -
setEnabled
public void setEnabled(boolean enabled) -
getIntervalMs
public long getIntervalMs() -
setIntervalMs
public void setIntervalMs(long intervalMs) -
getBatchSize
public int getBatchSize() -
setBatchSize
public void setBatchSize(int batchSize) -
getMaxRetries
public int getMaxRetries() -
setMaxRetries
public void setMaxRetries(int maxRetries) -
getSendTimeoutMs
public long getSendTimeoutMs() -
setSendTimeoutMs
public void setSendTimeoutMs(long sendTimeoutMs) -
getLockTtlMs
public long getLockTtlMs() -
setLockTtlMs
public void setLockTtlMs(long lockTtlMs) -
getLockRenewMarginMs
public long getLockRenewMarginMs() -
setLockRenewMarginMs
public void setLockRenewMarginMs(long lockRenewMarginMs) -
getBackoffBaseMs
public long getBackoffBaseMs() -
setBackoffBaseMs
public void setBackoffBaseMs(long backoffBaseMs) -
getBackoffMaxMs
public long getBackoffMaxMs() -
setBackoffMaxMs
public void setBackoffMaxMs(long backoffMaxMs)
-