Class ReceiveEndpointObservable

Namespace

MassTransit.Observables

Assembly

MassTransit.Abstractions.dll

public class ReceiveEndpointObservable : Connectable<IReceiveEndpointObserver>, IReceiveEndpointObserver

Inheritance

object

Connectable<IReceiveEndpointObserver>

ReceiveEndpointObservable

Implements

IReceiveEndpointObserver

Inherited Members

Connectable<IReceiveEndpointObserver>.Connect(IReceiveEndpointObserver)

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

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

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

Connectable<IReceiveEndpointObserver>.Count

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ReceiveEndpointObservable()

public ReceiveEndpointObservable()

Methods

Completed(ReceiveEndpointCompleted)

Called when the receive endpoint has completed

public Task Completed(ReceiveEndpointCompleted completed)

Parameters

completed ReceiveEndpointCompleted

Returns

Task

Faulted(ReceiveEndpointFaulted)

Called when the receive endpoint faults

public Task Faulted(ReceiveEndpointFaulted faulted)

Parameters

faulted ReceiveEndpointFaulted

Returns

Task

Ready(ReceiveEndpointReady)

Called when the receive endpoint is ready to receive messages

public Task Ready(ReceiveEndpointReady ready)

Parameters

ready ReceiveEndpointReady

Returns

Task

Stopping(ReceiveEndpointStopping)

Called when the receive endpoint is being stopped, prior to actually stopping

public Task Stopping(ReceiveEndpointStopping stopping)

Parameters

stopping ReceiveEndpointStopping

Returns

Task