Interface IBusControl

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public interface IBusControl : IBus, IPublishEndpoint, IPublishEndpointProvider, IPublishObserverConnector, ISendEndpointProvider, ISendObserverConnector, IConsumePipeConnector, IRequestPipeConnector, IConsumeMessageObserverConnector, IConsumeObserverConnector, IReceiveObserverConnector, IReceiveEndpointObserverConnector, IReceiveConnector, IEndpointConfigurationObserverConnector, IProbeSite

Inherited Members

IBus.Address

IBus.Topology

IPublishEndpoint.Publish<T>(T, CancellationToken)

IPublishEndpoint.Publish<T>(T, IPipe<PublishContext<T>>, CancellationToken)

IPublishEndpoint.Publish<T>(T, IPipe<PublishContext>, CancellationToken)

IPublishEndpoint.Publish(object, CancellationToken)

IPublishEndpoint.Publish(object, IPipe<PublishContext>, CancellationToken)

IPublishEndpoint.Publish(object, Type, CancellationToken)

IPublishEndpoint.Publish(object, Type, IPipe<PublishContext>, CancellationToken)

IPublishEndpoint.Publish<T>(object, CancellationToken)

IPublishEndpoint.Publish<T>(object, IPipe<PublishContext<T>>, CancellationToken)

IPublishEndpoint.Publish<T>(object, IPipe<PublishContext>, CancellationToken)

IPublishEndpointProvider.GetPublishSendEndpoint<T>()

IPublishObserverConnector.ConnectPublishObserver(IPublishObserver)

ISendEndpointProvider.GetSendEndpoint(Uri)

ISendObserverConnector.ConnectSendObserver(ISendObserver)

IConsumePipeConnector.ConnectConsumePipe<T>(IPipe<ConsumeContext<T>>)

IConsumePipeConnector.ConnectConsumePipe<T>(IPipe<ConsumeContext<T>>, ConnectPipeOptions)

IRequestPipeConnector.ConnectRequestPipe<T>(Guid, IPipe<ConsumeContext<T>>)

IConsumeMessageObserverConnector.ConnectConsumeMessageObserver<T>(IConsumeMessageObserver<T>)

IConsumeObserverConnector.ConnectConsumeObserver(IConsumeObserver)

IReceiveObserverConnector.ConnectReceiveObserver(IReceiveObserver)

IReceiveEndpointObserverConnector.ConnectReceiveEndpointObserver(IReceiveEndpointObserver)

IReceiveConnector.ConnectReceiveEndpoint(IEndpointDefinition, IEndpointNameFormatter, Action<IReceiveEndpointConfigurator>)

IReceiveConnector.ConnectReceiveEndpoint(string, Action<IReceiveEndpointConfigurator>)

IEndpointConfigurationObserverConnector.ConnectEndpointConfigurationObserver(IEndpointConfigurationObserver)

IProbeSite.Probe(ProbeContext)

Extension Methods

BusControlHealthExtensions.WaitForHealthStatus(IBusControl, BusHealthStatus, CancellationToken)

BusControlHealthExtensions.WaitForHealthStatus(IBusControl, BusHealthStatus, TimeSpan)

RoutingSlipExtensions.Execute<T>(T, RoutingSlip)

BatchProduceExtensions.PublishBatch(IPublishEndpoint, IEnumerable<object>, IPipe<PublishContext>, CancellationToken)

BatchProduceExtensions.PublishBatch(IPublishEndpoint, IEnumerable<object>, Action<PublishContext>, CancellationToken)

BatchProduceExtensions.PublishBatch(IPublishEndpoint, IEnumerable<object>, Func<PublishContext, Task>, CancellationToken)

BatchProduceExtensions.PublishBatch(IPublishEndpoint, IEnumerable<object>, CancellationToken)

BatchProduceExtensions.PublishBatch(IPublishEndpoint, IEnumerable<object>, Type, IPipe<PublishContext>, CancellationToken)

BatchProduceExtensions.PublishBatch(IPublishEndpoint, IEnumerable<object>, Type, Action<PublishContext>, CancellationToken)

BatchProduceExtensions.PublishBatch(IPublishEndpoint, IEnumerable<object>, Type, Func<PublishContext, Task>, CancellationToken)

BatchProduceExtensions.PublishBatch(IPublishEndpoint, IEnumerable<object>, Type, CancellationToken)

BatchProduceExtensions.PublishBatch<T>(IPublishEndpoint, IEnumerable<T>, IPipe<PublishContext<T>>, CancellationToken)

BatchProduceExtensions.PublishBatch<T>(IPublishEndpoint, IEnumerable<T>, Action<PublishContext<T>>, CancellationToken)

BatchProduceExtensions.PublishBatch<T>(IPublishEndpoint, IEnumerable<T>, Func<PublishContext<T>, Task>, CancellationToken)

BatchProduceExtensions.PublishBatch<T>(IPublishEndpoint, IEnumerable<T>, CancellationToken)

PublishExecuteExtensions.Publish(IPublishEndpoint, object, Action<PublishContext>, CancellationToken)

PublishExecuteExtensions.Publish(IPublishEndpoint, object, Func<PublishContext, Task>, CancellationToken)

PublishExecuteExtensions.Publish(IPublishEndpoint, object, Type, Action<PublishContext>, CancellationToken)

PublishExecuteExtensions.Publish(IPublishEndpoint, object, Type, Func<PublishContext, Task>, CancellationToken)

PublishExecuteExtensions.Publish<T>(IPublishEndpoint, object, Action<PublishContext<T>>, CancellationToken)

PublishExecuteExtensions.Publish<T>(IPublishEndpoint, object, Func<PublishContext<T>, Task>, CancellationToken)

PublishExecuteExtensions.Publish<T>(IPublishEndpoint, T, Action<PublishContext<T>>, CancellationToken)

PublishExecuteExtensions.Publish<T>(IPublishEndpoint, T, Func<PublishContext<T>, Task>, CancellationToken)

HostConnectReceiveEndpointExtensions.ConnectReceiveEndpoint(IReceiveConnector, Action<IReceiveEndpointConfigurator>?)

HostConnectReceiveEndpointExtensions.ConnectResponseEndpoint(IReceiveConnector, IEndpointNameFormatter?, Action<IReceiveEndpointConfigurator>?)

Methods

CheckHealth()

Returns the health of the bus, including all receive endpoints

BusHealthResult CheckHealth()

Returns

BusHealthResult

StartAsync(CancellationToken)

Starts the bus (assuming the battery isn't dead). Once the bus has been started it cannot be started again, even after it has been stopped.

Task<BusHandle> StartAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task<BusHandle>

The BusHandle for the started bus. This is no longer needed, as calling Stop on the IBusControl will stop the bus equally well.

StopAsync(CancellationToken)

Stops the bus if it has been started. If the bus hasn't been started, the method returns without any warning.

Task StopAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task