| Package | Description | 
|---|---|
| com.rabbitmq.client.impl.recovery | 
 Implementation of connection and topology recovery. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
protected BiPredicate<? super RecordedQueue,Exception> | 
TopologyRecoveryRetryHandlerBuilder.queueRecoveryRetryCondition  | 
protected BiPredicate<? super RecordedQueue,Exception> | 
DefaultRetryHandler.queueRecoveryRetryCondition  | 
| Modifier and Type | Method and Description | 
|---|---|
RecordedQueue | 
RecordedQueue.arguments(Map<String,Object> value)  | 
RecordedQueue | 
RecordedQueue.autoDelete(boolean value)  | 
RecordedQueue | 
RecordedQueue.durable(boolean value)  | 
RecordedQueue | 
RecordedQueue.exclusive(boolean value)  | 
RecordedQueue | 
RetryContext.queue()
The to-be-recovered entity as a queue. 
 | 
RecordedQueue | 
RecordedQueue.recoveredQueueNameSupplier(RecoveredQueueNameSupplier recoveredQueueNameSupplier)  | 
RecordedQueue | 
RecordedQueue.serverNamed(boolean value)  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,RecordedQueue> | 
AutorecoveringConnection.getRecordedQueues()  | 
| Modifier and Type | Method and Description | 
|---|---|
default boolean | 
TopologyRecoveryFilter.filterQueue(RecordedQueue recordedQueue)
Decides whether a queue is recovered or not. 
 | 
String | 
RecoveredQueueNameSupplier.getNameToUseForRecovery(RecordedQueue recordedQueue)
Get the queue name to use when recovering this RecordedQueue entity 
 | 
void | 
AutorecoveringConnection.recoverQueue(String oldName,
            RecordedQueue q,
            boolean retry)
Recover the queue. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
TopologyRecoveryRetryHandlerBuilder | 
TopologyRecoveryRetryHandlerBuilder.queueRecoveryRetryCondition(BiPredicate<? super RecordedQueue,Exception> queueRecoveryRetryCondition)  | 
| Constructor and Description | 
|---|
DefaultRetryHandler(BiPredicate<? super RecordedQueue,Exception> queueRecoveryRetryCondition,
                   BiPredicate<? super RecordedExchange,Exception> exchangeRecoveryRetryCondition,
                   BiPredicate<? super RecordedBinding,Exception> bindingRecoveryRetryCondition,
                   BiPredicate<? super RecordedConsumer,Exception> consumerRecoveryRetryCondition,
                   DefaultRetryHandler.RetryOperation<?> queueRecoveryRetryOperation,
                   DefaultRetryHandler.RetryOperation<?> exchangeRecoveryRetryOperation,
                   DefaultRetryHandler.RetryOperation<?> bindingRecoveryRetryOperation,
                   DefaultRetryHandler.RetryOperation<?> consumerRecoveryRetryOperation,
                   int retryAttempts,
                   BackoffPolicy backoffPolicy)  | 
Copyright © 2021 VMware, Inc. or its affiliates.. All rights reserved.