Class TopologyRecoveryExceptionHandler

Namespace

RabbitMQ.Client

Assembly

RabbitMQ.Client.dll

Custom logic for handling topology recovery exceptions that match the specified filters.

public class TopologyRecoveryExceptionHandler

Inheritance

object

TopologyRecoveryExceptionHandler

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Properties

BindingRecoveryExceptionCondition

Decides which binding recovery exceptions the custom exception handler is applied to. Default condition applies the exception handler to all binding recovery exceptions.

public Func<IRecordedBinding, Exception, bool> BindingRecoveryExceptionCondition { get; set; }

Property Value

Func<IRecordedBinding, Exception, bool>

BindingRecoveryExceptionHandlerAsync

Retries, or otherwise handles, an exception thrown when attempting to recover a binding.

public Func<IRecordedBinding, Exception, IConnection, Task>? BindingRecoveryExceptionHandlerAsync { get; set; }

Property Value

Func<IRecordedBinding, Exception, IConnection, Task>

ConsumerRecoveryExceptionCondition

Decides which consumer recovery exceptions the custom exception handler is applied to. Default condition applies the exception handler to all consumer recovery exceptions.

public Func<IRecordedConsumer, Exception, bool> ConsumerRecoveryExceptionCondition { get; set; }

Property Value

Func<IRecordedConsumer, Exception, bool>

ConsumerRecoveryExceptionHandlerAsync

Retries, or otherwise handles, an exception thrown when attempting to recover a consumer.

public Func<IRecordedConsumer, Exception, IConnection, Task>? ConsumerRecoveryExceptionHandlerAsync { get; set; }

Property Value

Func<IRecordedConsumer, Exception, IConnection, Task>

ExchangeRecoveryExceptionCondition

Decides which exchange recovery exceptions the custom exception handler is applied to. Default condition applies the exception handler to all exchange recovery exceptions.

public Func<IRecordedExchange, Exception, bool> ExchangeRecoveryExceptionCondition { get; set; }

Property Value

Func<IRecordedExchange, Exception, bool>

ExchangeRecoveryExceptionHandlerAsync

Retries, or otherwise handles, an exception thrown when attempting to recover an exchange.

public Func<IRecordedExchange, Exception, IConnection, Task>? ExchangeRecoveryExceptionHandlerAsync { get; set; }

Property Value

Func<IRecordedExchange, Exception, IConnection, Task>

QueueRecoveryExceptionCondition

Decides which queue recovery exceptions the custom exception handler is applied to. Default condition applies the exception handler to all queue recovery exceptions.

public Func<IRecordedQueue, Exception, bool> QueueRecoveryExceptionCondition { get; set; }

Property Value

Func<IRecordedQueue, Exception, bool>

QueueRecoveryExceptionHandlerAsync

Retries, or otherwise handles, an exception thrown when attempting to recover a queue.

public Func<IRecordedQueue, Exception, IConnection, Task>? QueueRecoveryExceptionHandlerAsync { get; set; }

Property Value

Func<IRecordedQueue, Exception, IConnection, Task>