Class ChannelPool.ChannelPoolItem

Inheritance

object

ChannelPool.ChannelPoolItem

Implements

IAsyncDisposable

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Volo.Abp.RabbitMQ

Assembly: Volo.Abp.RabbitMQ.dll

Syntax

protected class ChannelPool.ChannelPoolItem : IAsyncDisposable

Constructors

ChannelPoolItem(IChannel)

Declaration

public ChannelPoolItem(IChannel channel)

Parameters

Type	Name	Description
IChannel	channel

Properties

Channel

Declaration

public IChannel Channel { get; }

Property Value

Type	Description
IChannel

IsInUse

Declaration

public bool IsInUse { get; }

Property Value

Type	Description
bool

Methods

Acquire()

Declaration

public void Acquire()

DisposeAsync()

Declaration

public ValueTask DisposeAsync()

Returns

Type	Description
ValueTask

Release()

Declaration

public void Release()

WaitIfInUse(TimeSpan)

Declaration

public void WaitIfInUse(TimeSpan timeout)

Parameters

Type	Name	Description
TimeSpan	timeout

Implements

IAsyncDisposable

Extension Methods

AbpObjectExtensions.As<T>(object)

AbpObjectExtensions.To<T>(object)

LockExtensions.Locking(object, Action)

LockExtensions.Locking<TResult>(object, Func<TResult>)

AbpObjectExtensions.If<T>(T, bool, Action<T>)

AbpObjectExtensions.If<T>(T, bool, Func<T, T>)

AbpObjectExtensions.IsIn<T>(T, IEnumerable<T>)

AbpObjectExtensions.IsIn<T>(T, params T[])

AbpQueryableExtensions.OrderByIf<T, TQueryable>(TQueryable, bool, string)

AbpQueryableExtensions.PageBy<T, TQueryable>(TQueryable, int, int)

AbpQueryableExtensions.WhereIf<T, TQueryable>(TQueryable, bool, Expression<Func<T, bool>>)

AbpQueryableExtensions.WhereIf<T, TQueryable>(TQueryable, bool, Expression<Func<T, int, bool>>)

AbpOpenIddictQueryableExtensions.SkipIf<T, TQueryable>(TQueryable, bool, int?)

AbpOpenIddictQueryableExtensions.TakeIf<T, TQueryable>(TQueryable, bool, int?)

LockExtensions.Locking<T>(T, Action<T>)

LockExtensions.Locking<T, TResult>(T, Func<T, TResult>)