Class ChannelPool

Inheritance
System.Object
ChannelPool
Implements
IDisposable
ISingletonDependency
Namespace: Volo.Abp.RabbitMQ
Assembly: Volo.Abp.RabbitMQ.dll
Syntax
public class ChannelPool : object, 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<System.String, ChannelPool.ChannelPoolItem>

ConnectionPool

Declaration
protected IConnectionPool ConnectionPool { get; }
Property Value
Type Description
IConnectionPool

IsDisposed

Declaration
protected bool IsDisposed { get; }
Property Value
Type Description
System.Boolean

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
System.String channelName
System.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
System.String channelName
System.String connectionName
Returns
Type Description
IModel

Dispose()

Declaration
public void Dispose()

Implements

IDisposable
ISingletonDependency

Extension Methods