Class ConsumeObservable

Namespace

MassTransit.Observables

Assembly

MassTransit.Abstractions.dll

public class ConsumeObservable : Connectable<IConsumeObserver>, IConsumeObserver

Inheritance

object

Connectable<IConsumeObserver>

ConsumeObservable

Implements

IConsumeObserver

Inherited Members

Connectable<IConsumeObserver>.Connect(IConsumeObserver)

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

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

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

Connectable<IConsumeObserver>.Count

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ConsumeObservable()

public ConsumeObservable()

Methods

ConsumeFault<T>(ConsumeContext<T>, Exception)

Called after the message has been dispatched to all consumers when one or more exceptions have occurred

public Task ConsumeFault<T>(ConsumeContext<T> context, Exception exception) where T : class

Parameters

context ConsumeContext<T>

exception Exception

Returns

Task

Type Parameters

T

PostConsume<T>(ConsumeContext<T>)

Called after the message has been dispatched to all consumers - note that in the case of an exception this method is not called, and the DispatchFaulted method is called instead

public Task PostConsume<T>(ConsumeContext<T> context) where T : class

Parameters

context ConsumeContext<T>

Returns

Task

Type Parameters

T

PreConsume<T>(ConsumeContext<T>)

Called before a message is dispatched to any consumers

public Task PreConsume<T>(ConsumeContext<T> context) where T : class

Parameters

context ConsumeContext<T>

The consume context

Returns

Task

Type Parameters

T