Class ConnectionPool

Inheritance

object

ConnectionPool

Implements

IConnectionPool

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 ConnectionPool : IConnectionPool, IDisposable, ISingletonDependency

Constructors

ConnectionPool(IOptions<AbpRabbitMqOptions>)

Declaration

public ConnectionPool(IOptions<AbpRabbitMqOptions> options)

Parameters

Type	Name	Description
IOptions<AbpRabbitMqOptions>	options

Properties

Connections

Declaration

protected ConcurrentDictionary<string, Lazy<IConnection>> Connections { get; }

Property Value

Type	Description
ConcurrentDictionary<string, Lazy<IConnection>>

Options

Declaration

protected AbpRabbitMqOptions Options { get; }

Property Value

Type	Description
AbpRabbitMqOptions

Methods

Dispose()

Declaration

public void Dispose()

Get(string?)

Declaration

public virtual IConnection Get(string? connectionName = null)

Parameters

Type	Name	Description
string	connectionName

Returns

Type	Description
IConnection

GetConnection(string, ConnectionFactory)

Declaration

protected virtual IConnection GetConnection(string connectionName, ConnectionFactory connectionFactory)

Parameters

Type	Name	Description
string	connectionName
ConnectionFactory	connectionFactory

Returns

Type	Description
IConnection

Implements

IConnectionPool

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