Interface ITransportSupervisor<T>

Namespace

MassTransit.Transports

Assembly

MassTransit.Abstractions.dll

public interface ITransportSupervisor<out T> : ISupervisor<T>, ISupervisor, IAgent<T>, IAgent, IPipeContextSource<T>, IProbeSite where T : class, PipeContext

Type Parameters

T

Inherited Members

ISupervisor.Add(IAgent)

ISupervisor.PeakActiveCount

ISupervisor.TotalCount

IAgent.Stop(StopContext)

IAgent.Ready

IAgent.Completed

IAgent.Stopping

IAgent.Stopped

IPipeContextSource<T>.Send(IPipe<T>, CancellationToken)

IProbeSite.Probe(ProbeContext)

Extension Methods

AgentExtensions.Stop(IAgent, string, CancellationToken)

AgentExtensions.Stop(IAgent, CancellationToken)

Properties

ConsumeStopping

CancellationToken ConsumeStopping { get; }

Property Value

CancellationToken

SendStopping

CancellationToken SendStopping { get; }

Property Value

CancellationToken

Methods

AddConsumeAgent<TAgent>(TAgent)

void AddConsumeAgent<TAgent>(TAgent agent) where TAgent : IAgent

Parameters

agent TAgent

Type Parameters

TAgent

AddSendAgent<TAgent>(TAgent)

void AddSendAgent<TAgent>(TAgent agent) where TAgent : IAgent

Parameters

agent TAgent

Type Parameters

TAgent