Uses of Class
com.broadleafcommerce.common.messaging.retry.nonblocking.NonBlockingFixedRetryInfo

Packages that use NonBlockingFixedRetryInfo

Package	Description
com.broadleafcommerce.common.messaging.retry.nonblocking

Uses of NonBlockingFixedRetryInfo in com.broadleafcommerce.common.messaging.retry.nonblocking

Methods in com.broadleafcommerce.common.messaging.retry.nonblocking that return NonBlockingFixedRetryInfo

Modifier and Type	Method	Description
protected NonBlockingFixedRetryInfo	NonBlockingRetryErrorHandler.identifyLastRetryPhase(List<NonBlockingFixedRetryInfo> retries)	Identify the last retry config in the list of retry configs
protected NonBlockingFixedRetryInfo	NonBlockingRetryErrorHandler.identifyRetryPhase(List<NonBlockingFixedRetryInfo> retries, org.springframework.messaging.MessagingException messagingException, AtomicInteger counter)	Based on the count, identify the current retry config that should be considered

Methods in com.broadleafcommerce.common.messaging.retry.nonblocking that return types with arguments of type NonBlockingFixedRetryInfo

Modifier and Type	Method	Description
Map<String,List<NonBlockingFixedRetryInfo>>	NonBlockingRetryProperties.getBindings()	The ordered list of retry configurations associated by the original consumer binding

Methods in com.broadleafcommerce.common.messaging.retry.nonblocking with parameters of type NonBlockingFixedRetryInfo

Modifier and Type	Method	Description
protected org.springframework.beans.factory.support.RootBeanDefinition	NonBlockingRetryConsumerBeanDefinitionRegistryPostProcessor.buildErrorHandler(String originalConsumerBinding, NonBlockingFixedRetryInfo retryInfo)	Establish the error handler bean definition responsible for navigating the retry lifecycle for the non-blocking case.
protected org.springframework.classify.BinaryExceptionClassifier	NonBlockingRetryErrorHandler.buildExceptionClassifier(NonBlockingFixedRetryInfo retryInfo)	Build the BinaryExceptionClassifier instance responsible for inspecting exceptions and determining inclusion or exclusion, if applicable.
protected void	NonBlockingRetryErrorHandler.sendToDlq(NonBlockingFixedRetryInfo finalRetry, int attempt, org.springframework.messaging.support.ErrorMessage errorMessage, org.springframework.messaging.Message<?> original)	Send a failed message to a DLQ
protected void	NonBlockingRetryErrorHandler.sendToRetryChannel(NonBlockingFixedRetryInfo info, int attempt, org.springframework.messaging.Message<?> original)	Send a failed message to a configured retry channel
protected void	NonBlockingRetryEnvironmentPostProcessor.setupKafkaConsumer(NonBlockingFixedRetryInfo retryInfo, org.springframework.core.env.ConfigurableEnvironment environment, Map<String,Object> propertySource)	Set up spring cloud stream properties related to retry consumption for kafka for the non-blocking case.
protected void	NonBlockingRetryEnvironmentPostProcessor.setupPubSubConsumer(NonBlockingFixedRetryInfo retryInfo, org.springframework.core.env.ConfigurableEnvironment environment, Map<String,Object> propertySource)	Set up spring cloud stream properties related to retry consumption for pubsub for the non-blocking case.
protected void	NonBlockingRetryEnvironmentPostProcessor.setupRetryBindingIfApplicable(String originalConsumerBinding, NonBlockingFixedRetryInfo retryInfo, org.springframework.core.env.ConfigurableEnvironment environment, Map<String,Object> propertySource)	Set up the spring cloud stream retry binding consumer, producer, and DLQ properties, if they don't already exist.
protected void	NonBlockingRetryEnvironmentPostProcessor.setupRetryConsumer(String originalConsumerBinding, NonBlockingFixedRetryInfo retryInfo, org.springframework.core.env.ConfigurableEnvironment environment, Map<String,Object> propertySource)	Set up the spring cloud stream retry consumer binding property, if it does not already exist.
protected void	NonBlockingRetryEnvironmentPostProcessor.setupRetryProducer(NonBlockingFixedRetryInfo retryInfo, org.springframework.core.env.ConfigurableEnvironment environment, Map<String,Object> propertySource)	Set up the spring cloud stream retry producer binding property, if it does not already exist.
protected void	NonBlockingRetryEnvironmentPostProcessor.validateRetryInfo(NonBlockingFixedRetryInfo retryInfo, List<String> usedNames)	Validate the non-blocking retry configuration

Method parameters in com.broadleafcommerce.common.messaging.retry.nonblocking with type arguments of type NonBlockingFixedRetryInfo

Modifier and Type	Method	Description
protected NonBlockingFixedRetryInfo	NonBlockingRetryErrorHandler.identifyLastRetryPhase(List<NonBlockingFixedRetryInfo> retries)	Identify the last retry config in the list of retry configs
protected NonBlockingFixedRetryInfo	NonBlockingRetryErrorHandler.identifyRetryPhase(List<NonBlockingFixedRetryInfo> retries, org.springframework.messaging.MessagingException messagingException, AtomicInteger counter)	Based on the count, identify the current retry config that should be considered
void	NonBlockingRetryProperties.setBindings(Map<String,List<NonBlockingFixedRetryInfo>> bindings)	The ordered list of retry configurations associated by the original consumer binding