Class SendObservable

Namespace

MassTransit.Observables

Assembly

MassTransit.Abstractions.dll

public class SendObservable : Connectable<ISendObserver>, ISendObserver

Inheritance

object

Connectable<ISendObserver>

SendObservable

Implements

ISendObserver

Inherited Members

Connectable<ISendObserver>.Connect(ISendObserver)

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

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

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

Connectable<ISendObserver>.Count

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

SendObservable()

public SendObservable()

Methods

PostSend<T>(SendContext<T>)

Called after the message is sent to the transport (and confirmed by the transport if supported)

public Task PostSend<T>(SendContext<T> context) where T : class

Parameters

context SendContext<T>

The message send context

Returns

Task

Type Parameters

T

The message type

PreSend<T>(SendContext<T>)

Called before the message is sent to the transport

public Task PreSend<T>(SendContext<T> context) where T : class

Parameters

context SendContext<T>

The message send context

Returns

Task

Type Parameters

T

The message type

SendFault<T>(SendContext<T>, Exception)

Called when the message fails to send to the transport, including the exception that was thrown

public Task SendFault<T>(SendContext<T> context, Exception exception) where T : class

Parameters

context SendContext<T>

The message send context

exception Exception

The exception from the transport

Returns

Task

Type Parameters

T

The message type