Table of Contents

Class FilterObservable<TContext>

Namespace
MassTransit.Observables
Assembly
MassTransit.Abstractions.dll
public class FilterObservable<TContext> : Connectable<IFilterObserver<TContext>>, IFilterObserver<TContext> where TContext : class, PipeContext

Type Parameters

TContext
Inheritance
FilterObservable<TContext>
Implements
IFilterObserver<TContext>
Inherited Members

Constructors

FilterObservable()

public FilterObservable()

Methods

PostSend(TContext)

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 PostSend(TContext context)

Parameters

context TContext

Returns

Task

PreSend(TContext)

Called before a message is dispatched to any consumers

public Task PreSend(TContext context)

Parameters

context TContext

The consume context

Returns

Task

SendFault(TContext, Exception)

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

public Task SendFault(TContext context, Exception exception)

Parameters

context TContext
exception Exception

Returns

Task