Class RetryObservable

Namespace

MassTransit.Observables

Assembly

MassTransit.Abstractions.dll

public class RetryObservable : Connectable<IRetryObserver>, IRetryObserver

Inheritance

object

Connectable<IRetryObserver>

RetryObservable

Implements

IRetryObserver

Inherited Members

Connectable<IRetryObserver>.Connect(IRetryObserver)

Connectable<IRetryObserver>.ForEachAsync(Func<IRetryObserver, Task>)

Connectable<IRetryObserver>.ForEach(Action<IRetryObserver>)

Connectable<IRetryObserver>.All(Func<IRetryObserver, bool>)

Connectable<IRetryObserver>.Count

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

RetryObservable()

public RetryObservable()

Methods

PostCreate<T>(RetryPolicyContext<T>)

Called before a message is dispatched to any consumers

public Task PostCreate<T>(RetryPolicyContext<T> context) where T : class, PipeContext

Parameters

context RetryPolicyContext<T>

The consume context

Returns

Task

Type Parameters

T

PostFault<T>(RetryContext<T>)

Called after a fault has occurred, but will be retried

public Task PostFault<T>(RetryContext<T> context) where T : class, PipeContext

Parameters

context RetryContext<T>

Returns

Task

Type Parameters

T

PreRetry<T>(RetryContext<T>)

Called immediately before an exception will be retried

public Task PreRetry<T>(RetryContext<T> context) where T : class, PipeContext

Parameters

context RetryContext<T>

Returns

Task

Type Parameters

T

RetryComplete<T>(RetryContext<T>)

Called when the retry filter retried at least once, and the context completed successfully.

public Task RetryComplete<T>(RetryContext<T> context) where T : class, PipeContext

Parameters

context RetryContext<T>

Returns

Task

Type Parameters

T

RetryFault(RetryContext)

public Task RetryFault(RetryContext context)

Parameters

context RetryContext

Returns

Task

RetryFault<T>(RetryContext<T>)

Called when the retry filter is no longer going to retry, and the context is faulted.

public Task RetryFault<T>(RetryContext<T> context) where T : class, PipeContext

Parameters

context RetryContext<T>

Returns

Task

Type Parameters

T