Class ConcurrencyLimitExtensions

Namespace

MassTransit

Assembly

MassTransit.Abstractions.dll

public static class ConcurrencyLimitExtensions

Inheritance

object

ConcurrencyLimitExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

SetConcurrencyLimit(IPipe<CommandContext>, int)

Set the concurrency limit of the filter

public static Task SetConcurrencyLimit(this IPipe<CommandContext> pipe, int concurrencyLimit)

Parameters

pipe IPipe<CommandContext>

concurrencyLimit int

Returns

Task