public abstract class TopologyRecoveryRetryLogic extends Object
DefaultRetryHandler
.
They're composed and used with the TopologyRecoveryRetryHandlerBuilder
.DefaultRetryHandler
,
RetryHandler
,
TopologyRecoveryRetryHandlerBuilder
Modifier and Type | Field and Description |
---|---|
static BiPredicate<RecordedEntity,Exception> |
CHANNEL_CLOSED_NOT_FOUND
Channel has been closed because of a resource that doesn't exist.
|
static DefaultRetryHandler.RetryOperation<Void> |
RECOVER_BINDING
Recover a binding.
|
static DefaultRetryHandler.RetryOperation<Void> |
RECOVER_BINDING_QUEUE
Recover the destination queue of a binding.
|
static DefaultRetryHandler.RetryOperation<Void> |
RECOVER_CHANNEL
Recover a channel.
|
static DefaultRetryHandler.RetryOperation<String> |
RECOVER_CONSUMER
Recover a consumer.
|
static DefaultRetryHandler.RetryOperation<Void> |
RECOVER_CONSUMER_QUEUE
Recover the queue of a consumer.
|
static DefaultRetryHandler.RetryOperation<Void> |
RECOVER_CONSUMER_QUEUE_BINDINGS
Recover all the bindings of the queue of a consumer.
|
static DefaultRetryHandler.RetryOperation<Void> |
RECOVER_PREVIOUS_AUTO_DELETE_QUEUES
Recover earlier auto-delete or exclusive queues that share the same channel as this retry context
|
static DefaultRetryHandler.RetryOperation<String> |
RECOVER_PREVIOUS_CONSUMERS
Recover earlier consumers that share the same channel as this retry context
|
static DefaultRetryHandler.RetryOperation<Void> |
RECOVER_PREVIOUS_QUEUE_BINDINGS
Recover earlier bindings that share the same queue as this retry context
|
static DefaultRetryHandler.RetryOperation<Void> |
RECOVER_QUEUE
Recover a queue
|
static TopologyRecoveryRetryHandlerBuilder |
RETRY_ON_QUEUE_NOT_FOUND_RETRY_HANDLER
Pre-configured
TopologyRecoveryRetryHandlerBuilder that retries recovery of bindings and consumers
when their respective queue is not found. |
Constructor and Description |
---|
TopologyRecoveryRetryLogic() |
public static final BiPredicate<RecordedEntity,Exception> CHANNEL_CLOSED_NOT_FOUND
public static final DefaultRetryHandler.RetryOperation<Void> RECOVER_CHANNEL
public static final DefaultRetryHandler.RetryOperation<Void> RECOVER_QUEUE
public static final DefaultRetryHandler.RetryOperation<Void> RECOVER_BINDING_QUEUE
public static final DefaultRetryHandler.RetryOperation<Void> RECOVER_BINDING
public static final DefaultRetryHandler.RetryOperation<Void> RECOVER_PREVIOUS_QUEUE_BINDINGS
public static final DefaultRetryHandler.RetryOperation<Void> RECOVER_CONSUMER_QUEUE
public static final DefaultRetryHandler.RetryOperation<Void> RECOVER_CONSUMER_QUEUE_BINDINGS
public static final DefaultRetryHandler.RetryOperation<String> RECOVER_CONSUMER
public static final DefaultRetryHandler.RetryOperation<String> RECOVER_PREVIOUS_CONSUMERS
public static final DefaultRetryHandler.RetryOperation<Void> RECOVER_PREVIOUS_AUTO_DELETE_QUEUES
public static final TopologyRecoveryRetryHandlerBuilder RETRY_ON_QUEUE_NOT_FOUND_RETRY_HANDLER
TopologyRecoveryRetryHandlerBuilder
that retries recovery of bindings and consumers
when their respective queue is not found.
This retry handler can be useful for long recovery processes, whereby auto-delete queues
can be deleted between queue recovery and binding/consumer recovery.
Also useful to retry channel-closed 404 errors that may arise with auto-delete queues during a cluster cycle.Copyright © 2022 VMware, Inc. or its affiliates.. All rights reserved.