Package com.broadleafcommerce.common.messaging.retry.blocking

Class BlockingRetryProperties

java.lang.Object

com.broadleafcommerce.common.messaging.retry.blocking.BlockingRetryProperties

@ConfigurationProperties("broadleaf.messaging.blocking.retry.cloud.stream")
public class BlockingRetryProperties
extends Object

Configure blocking retry. This is an opinionated configuration, but at the same time tries to compact different binder implementation concerns into a unified config. When isEnabled() is true:

1. Default to blocking retry with seek to current offset for kafka (i.e. BlockingFixedRetryInfo.Kafka.isSeekToCurrentRecordOnFailure() is true). If the default is changed, then in-memory Spring retry will be used instead, in which case, care should be taken to not exceed max.poll.interval.ms for the aggregate of the retry timeline when using Kafka.
2. Using in-memory Spring retry as the retry approach for all non-kafka binders
3. Configure which exceptions are retryable, allowing all if not specified
4. Standardize on fixed backoff via configuration
5. Specify a DLQ, if desired

Note - Consuming batches is not currently supported with this configuration.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BlockingRetryProperties.PubSub

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ENABLED_PROP
static final String	PREFIX

Constructor Summary

Constructors

Constructor	Description
BlockingRetryProperties()

Method Summary

Modifier and Type	Method	Description
protected boolean	canEqual(Object other)
boolean	equals(Object o)
Map<String,BlockingFixedRetryInfo>	getBindings()	The retry configurations associated by the original consumer bindings
BlockingRetryProperties.PubSub	getPubSub()
int	hashCode()
boolean	isEnabled()	Whether the blocking retry feature is enabled
void	setBindings(Map<String,BlockingFixedRetryInfo> bindings)	The retry configurations associated by the original consumer bindings
void	setEnabled(boolean enabled)	Whether the blocking retry feature is enabled
void	setPubSub(BlockingRetryProperties.PubSub pubSub)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

PREFIX

public static final String PREFIX

See Also:

• Constant Field Values

ENABLED_PROP

public static final String ENABLED_PROP

See Also:

• Constant Field Values

Constructor Details

BlockingRetryProperties

public BlockingRetryProperties()

Method Details

isEnabled

public boolean isEnabled()

Whether the blocking retry feature is enabled

getBindings

public Map<String,BlockingFixedRetryInfo> getBindings()

The retry configurations associated by the original consumer bindings

See Also:

• BlockingFixedRetryInfo

getPubSub

public BlockingRetryProperties.PubSub getPubSub()

setEnabled

public void setEnabled(boolean enabled)

Whether the blocking retry feature is enabled

setBindings

public void setBindings(Map<String,BlockingFixedRetryInfo> bindings)

The retry configurations associated by the original consumer bindings

See Also:

• BlockingFixedRetryInfo

setPubSub

public void setPubSub(BlockingRetryProperties.PubSub pubSub)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

canEqual

protected boolean canEqual(Object other)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object