Interface IReceiveEndpoint

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

A service endpoint has an inbound transport that pushes messages to consumers

public interface IReceiveEndpoint : ISendEndpointProvider, ISendObserverConnector, IPublishEndpointProvider, IPublishObserverConnector, IConsumePipeConnector, IRequestPipeConnector, IReceiveObserverConnector, IConsumeObserverConnector, IConsumeMessageObserverConnector, IProbeSite

Inherited Members

ISendEndpointProvider.GetSendEndpoint(Uri)

ISendObserverConnector.ConnectSendObserver(ISendObserver)

IPublishEndpointProvider.GetPublishSendEndpoint<T>()

IPublishObserverConnector.ConnectPublishObserver(IPublishObserver)

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

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

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

IReceiveObserverConnector.ConnectReceiveObserver(IReceiveObserver)

IConsumeObserverConnector.ConnectConsumeObserver(IConsumeObserver)

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

IProbeSite.Probe(ProbeContext)

Properties

InputAddress

Uri InputAddress { get; }

Property Value

Uri

Started

Task<ReceiveEndpointReady> Started { get; }

Property Value

Task<ReceiveEndpointReady>

Methods

Start(CancellationToken)

Start the receive endpoint

ReceiveEndpointHandle Start(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Cancel the start operation in progress

Returns

ReceiveEndpointHandle

An awaitable task that is completed once everything is started

Stop(CancellationToken)

Stop the receive endpoint.

Task Stop(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Cancel the stop operation in progress

Returns

Task

An awaitable task that is completed once everything is stopped