Class BusObservable

Namespace

MassTransit.Observables

Assembly

MassTransit.Abstractions.dll

public class BusObservable : Connectable<IBusObserver>, IBusObserver

Inheritance

object

Connectable<IBusObserver>

BusObservable

Implements

IBusObserver

Inherited Members

Connectable<IBusObserver>.Connect(IBusObserver)

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

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

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

Connectable<IBusObserver>.Count

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

BusObservable()

public BusObservable()

Methods

CreateFaulted(Exception)

Called when the bus fails to be created

public void CreateFaulted(Exception exception)

Parameters

exception Exception

PostCreate(IBus)

Called after the bus has been created.

public void PostCreate(IBus bus)

Parameters

bus IBus

PostStart(IBus, Task<BusReady>)

Called once the bus has started and is running

public Task PostStart(IBus bus, Task<BusReady> busReady)

Parameters

bus IBus

busReady Task<BusReady>

A task which is completed once the bus is ready and all receive endpoints are ready.

Returns

Task

PostStop(IBus)

Called when the bus has been stopped.

public Task PostStop(IBus bus)

Parameters

bus IBus

Returns

Task

PreStart(IBus)

Called when the bus is being started, before the actual Start commences.

public Task PreStart(IBus bus)

Parameters

bus IBus

Returns

Task

PreStop(IBus)

Called when the bus is being stopped, before the actual Stop commences.

public Task PreStop(IBus bus)

Parameters

bus IBus

Returns

Task

StartFaulted(IBus, Exception)

Called when the bus fails to start

public Task StartFaulted(IBus bus, Exception exception)

Parameters

bus IBus

exception Exception

Returns

Task

StopFaulted(IBus, Exception)

Called when the bus failed to Stop.

public Task StopFaulted(IBus bus, Exception exception)

Parameters

bus IBus

exception Exception

Returns

Task