Class ReceiveObservable

Namespace

MassTransit.Observables

Assembly

MassTransit.Abstractions.dll

public class ReceiveObservable : Connectable<IReceiveObserver>, IReceiveObserver

Inheritance

object

Connectable<IReceiveObserver>

ReceiveObservable

Implements

IReceiveObserver

Inherited Members

Connectable<IReceiveObserver>.Connect(IReceiveObserver)

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

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

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

Connectable<IReceiveObserver>.Count

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ReceiveObservable()

public ReceiveObservable()

Methods

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

Called when a message being consumed produced a fault

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

Parameters

context ConsumeContext<T>

The message consume context

duration TimeSpan

The consumer duration

consumerType string

The consumer type

exception Exception

The exception from the consumer

Returns

Task

Type Parameters

T

The message type

PostConsume<T>(ConsumeContext<T>, TimeSpan, string)

Called when a message has been consumed by a consumer

public Task PostConsume<T>(ConsumeContext<T> context, TimeSpan duration, string consumerType) where T : class

Parameters

context ConsumeContext<T>

The message consume context

duration TimeSpan

The consumer duration

consumerType string

The consumer type

Returns

Task

Type Parameters

T

The message type

PostReceive(ReceiveContext)

Called when the message has been received and acknowledged on the transport

public Task PostReceive(ReceiveContext context)

Parameters

context ReceiveContext

The receive context of the message

Returns

Task

PreReceive(ReceiveContext)

Called when a message has been delivered by the transport is about to be received by the endpoint

public Task PreReceive(ReceiveContext context)

Parameters

context ReceiveContext

The receive context of the message

Returns

Task

ReceiveFault(ReceiveContext, Exception)

Called when the transport receive faults

public Task ReceiveFault(ReceiveContext context, Exception exception)

Parameters

context ReceiveContext

The receive context of the message

exception Exception

The exception that was thrown

Returns

Task