Class ChannelPool

Inheritance

object

ChannelPool

Implements

IChannelPool

System.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
System.Collections.Concurrent.ConcurrentDictionary<TKey, TValue><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
Microsoft.Extensions.Logging.ILogger<TCategoryName><ChannelPool>

TotalDisposeWaitDuration

Declaration

protected TimeSpan TotalDisposeWaitDuration { get; set; }

Property Value

Type	Description
System.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
RabbitMQ.Client.IModel

Dispose()

Declaration

public void Dispose()

Implements

IChannelPool

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

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

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