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
-
Connectable<IFilterObserver<TContext>>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
PreSend(TContext)
Called before a message is dispatched to any consumers
public Task PreSend(TContext context)
Parameters
context
TContextThe consume context
Returns
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
TContextexception
Exception