K
- the key type.V
- the value type.T
- the delegate type.public abstract class AbstractRetryingMessageListenerAdapter<K,V,T> extends AbstractMessageListenerAdapter<K,V,T>
ConsumerSeekAware.ConsumerSeekCallback
delegate, logger
Constructor and Description |
---|
AbstractRetryingMessageListenerAdapter(T delegate,
org.springframework.retry.support.RetryTemplate retryTemplate)
Construct an instance with the supplied retry template.
|
AbstractRetryingMessageListenerAdapter(T delegate,
org.springframework.retry.support.RetryTemplate retryTemplate,
org.springframework.retry.RecoveryCallback<java.lang.Void> recoveryCallback)
Construct an instance with the supplied template and callback.
|
Modifier and Type | Method and Description |
---|---|
org.springframework.retry.RecoveryCallback<java.lang.Void> |
getRecoveryCallback() |
org.springframework.retry.support.RetryTemplate |
getRetryTemplate() |
onIdleContainer, onPartitionsAssigned, registerSeekCallback
public AbstractRetryingMessageListenerAdapter(T delegate, org.springframework.retry.support.RetryTemplate retryTemplate)
delegate
- the delegate listener.retryTemplate
- the template.public AbstractRetryingMessageListenerAdapter(T delegate, org.springframework.retry.support.RetryTemplate retryTemplate, org.springframework.retry.RecoveryCallback<java.lang.Void> recoveryCallback)
delegate
- the delegate listener.retryTemplate
- the template.recoveryCallback
- the recovery callback; if null, the exception will be
thrown to the container after retries are exhausted.