Uses of Class
com.broadleafcommerce.common.messaging.retry.blocking.BlockingFixedRetryInfo
Packages that use BlockingFixedRetryInfo
Package
Description
-
Uses of BlockingFixedRetryInfo in com.broadleafcommerce.common.messaging.autoconfigure.kafka
Methods in com.broadleafcommerce.common.messaging.autoconfigure.kafka with parameters of type BlockingFixedRetryInfoModifier and TypeMethodDescriptionprotected void
KafkaListenerContainerCustomizer.configureRetryableExceptions
(BlockingFixedRetryInfo retryInfo, org.springframework.kafka.listener.DefaultErrorHandler errorHandler) Configure the error handler for retryable exception behavior.protected org.springframework.util.backoff.BackOff
KafkaListenerContainerCustomizer.createBackoff
(BlockingFixedRetryInfo retryInfo) TheBackoff
instance to use between retries.protected org.springframework.kafka.listener.ConsumerRecordRecoverer
KafkaListenerContainerCustomizer.createRecordRecoverer
(String consumerBinding, String group, BlockingFixedRetryInfo retryInfo) Establish the recoverer used to handle a message after any applicable retry attempts are exhausted. -
Uses of BlockingFixedRetryInfo in com.broadleafcommerce.common.messaging.retry.blocking
Methods in com.broadleafcommerce.common.messaging.retry.blocking that return types with arguments of type BlockingFixedRetryInfoModifier and TypeMethodDescriptionBlockingRetryProperties.getBindings()
The retry configurations associated by the original consumer bindingsMethods in com.broadleafcommerce.common.messaging.retry.blocking with parameters of type BlockingFixedRetryInfoModifier and TypeMethodDescriptionprotected org.springframework.beans.factory.support.RootBeanDefinition
BlockingRetryConsumerBeanDefinitionRegistryPostProcessor.constructRetryTemplate
(BlockingFixedRetryInfo info) Create the bean definition informed by the Spring retry related config for the blocking case.protected void
BlockingRetryErrorHandler.sendToDlq
(BlockingFixedRetryInfo info, org.springframework.messaging.support.ErrorMessage errorMessage, org.springframework.messaging.Message<?> original) Send the message to the DLQ.Method parameters in com.broadleafcommerce.common.messaging.retry.blocking with type arguments of type BlockingFixedRetryInfoModifier and TypeMethodDescriptionvoid
BlockingRetryProperties.setBindings
(Map<String, BlockingFixedRetryInfo> bindings) The retry configurations associated by the original consumer bindings