Package | Description |
---|---|
com.rabbitmq.client |
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
|
com.rabbitmq.client.impl.recovery |
Implementation of connection and topology recovery.
|
Modifier and Type | Method and Description |
---|---|
RecordedEntity |
TopologyRecoveryException.getRecordedEntity() |
Constructor and Description |
---|
TopologyRecoveryException(String message,
Throwable cause,
RecordedEntity recordedEntity) |
Modifier and Type | Class and Description |
---|---|
class |
RecordedBinding |
class |
RecordedConsumer |
class |
RecordedExchange |
class |
RecordedExchangeBinding |
class |
RecordedNamedEntity |
class |
RecordedQueue |
class |
RecordedQueueBinding |
Modifier and Type | Field and Description |
---|---|
static BiPredicate<RecordedEntity,Exception> |
TopologyRecoveryRetryLogic.CHANNEL_CLOSED_NOT_FOUND
Channel has been closed because of a resource that doesn't exist.
|
Modifier and Type | Method and Description |
---|---|
RecordedEntity |
RetryContext.entity()
The to-be-recovered entity.
|
RecordedEntity |
RetryResult.getRecordedEntity()
The entity to recover.
|
Modifier and Type | Method and Description |
---|---|
protected RetryResult |
DefaultRetryHandler.doRetry(BiPredicate<RecordedEntity,Exception> condition,
DefaultRetryHandler.RetryOperation<?> operation,
RecordedEntity entity,
RetryContext context) |
protected void |
DefaultRetryHandler.log(RecordedEntity entity,
Exception exception,
int attempts) |
Modifier and Type | Method and Description |
---|---|
protected RetryResult |
DefaultRetryHandler.doRetry(BiPredicate<RecordedEntity,Exception> condition,
DefaultRetryHandler.RetryOperation<?> operation,
RecordedEntity entity,
RetryContext context) |
Constructor and Description |
---|
RetryContext(RecordedEntity entity,
Exception exception,
AutorecoveringConnection connection) |
RetryResult(RecordedEntity recordedEntity,
Object result) |
Copyright © 2021 VMware, Inc. or its affiliates.. All rights reserved.