Interface IBus

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

A bus is a logical element that includes a local endpoint and zero or more receive endpoints

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

Inherited Members

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

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>?)

Properties

Address

The InputAddress of the default bus endpoint

Uri Address { get; }

Property Value

Uri

Topology

The bus topology

IBusTopology Topology { get; }

Property Value

IBusTopology