Interface IReceiveObserver

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

An observer that can monitor a receive endpoint to track message consumption at the endpoint level.

public interface IReceiveObserver

Methods

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

Called when a message being consumed produced a fault

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

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

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

Task PreReceive(ReceiveContext context)

Parameters

context ReceiveContext

The receive context of the message

Returns

Task

ReceiveFault(ReceiveContext, Exception)

Called when the transport receive faults

Task ReceiveFault(ReceiveContext context, Exception exception)

Parameters

context ReceiveContext

The receive context of the message

exception Exception

The exception that was thrown

Returns

Task