Class ReceivePipe

Namespace

MassTransit.Middleware

Assembly

MassTransit.Abstractions.dll

public class ReceivePipe : IReceivePipe, IPipe<ReceiveContext>, IProbeSite, IConsumePipeConnector, IRequestPipeConnector, IConsumeMessageObserverConnector, IConsumeObserverConnector

Inheritance

object

ReceivePipe

Implements

IReceivePipe

IPipe<ReceiveContext>

IProbeSite

IConsumePipeConnector

IRequestPipeConnector

IConsumeMessageObserverConnector

IConsumeObserverConnector

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

Pipe.AddCallback<T>(IPipe<T>, Action<T>)

PipeExtensions.IsEmpty<T>(IPipe<T>?)

PipeExtensions.IsNotEmpty<T>(IPipe<T>?)

Constructors

ReceivePipe(IPipe<ReceiveContext>, IConsumePipe)

public ReceivePipe(IPipe<ReceiveContext> receivePipe, IConsumePipe consumePipe)

Parameters

receivePipe IPipe<ReceiveContext>

consumePipe IConsumePipe

Properties

Connected

Task is completed once a connection has been made to the consume pipe (any type of consumer, response handler, etc.

public Task Connected { get; }

Property Value

Task