Class PublishObservable

Namespace

MassTransit.Observables

Assembly

MassTransit.Abstractions.dll

public class PublishObservable : Connectable<IPublishObserver>, IPublishObserver, ISendObserver

Inheritance

object

Connectable<IPublishObserver>

PublishObservable

Implements

IPublishObserver

ISendObserver

Inherited Members

Connectable<IPublishObserver>.Connect(IPublishObserver)

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

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

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

Connectable<IPublishObserver>.Count

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

PublishObservable()

public PublishObservable()

Methods

PostPublish<T>(PublishContext<T>)

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

public Task PostPublish<T>(PublishContext<T> context) where T : class

Parameters

context PublishContext<T>

The message send context

Returns

Task

Type Parameters

T

The message type

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

PrePublish<T>(PublishContext<T>)

Called before the message is sent to the transport

public Task PrePublish<T>(PublishContext<T> context) where T : class

Parameters

context PublishContext<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

PublishFault<T>(PublishContext<T>, Exception)

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

public Task PublishFault<T>(PublishContext<T> context, Exception exception) where T : class

Parameters

context PublishContext<T>

The message send context

exception Exception

The exception from the transport

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