Class ChannelPool

Inheritance

object

ChannelPool

Implements

IChannelPool

IDisposable

ISingletonDependency

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

public class ChannelPool : IChannelPool, IDisposable, ISingletonDependency

Constructors

ChannelPool(IConnectionPool)

Declaration

public ChannelPool(IConnectionPool connectionPool)

Parameters

Type	Name	Description
IConnectionPool	connectionPool

Properties

Channels

Declaration

protected ConcurrentDictionary<string, ChannelPool.ChannelPoolItem> Channels { get; }

Property Value

Type	Description
ConcurrentDictionary<string, ChannelPool.ChannelPoolItem>

ConnectionPool

Declaration

protected IConnectionPool ConnectionPool { get; }

Property Value

Type	Description
IConnectionPool

IsDisposed

Declaration

protected bool IsDisposed { get; }

Property Value

Type	Description
bool

Logger

Declaration

public ILogger<ChannelPool> Logger { get; set; }

Property Value

Type	Description
ILogger<ChannelPool>

TotalDisposeWaitDuration

Declaration

protected TimeSpan TotalDisposeWaitDuration { get; set; }

Property Value

Type	Description
TimeSpan

Methods

Acquire(string?, string?)

Declaration

public virtual IChannelAccessor Acquire(string? channelName = null, string? connectionName = null)

Parameters

Type	Name	Description
string	channelName
string	connectionName

Returns

Type	Description
IChannelAccessor

CheckDisposed()

Declaration

protected void CheckDisposed()

CreateChannel(string, string?)

Declaration

protected virtual IModel CreateChannel(string channelName, string? connectionName)

Parameters

Type	Name	Description
string	channelName
string	connectionName

Returns

Type	Description
IModel

Dispose()

Declaration

public void Dispose()

Implements

IChannelPool

IDisposable

ISingletonDependency

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>)