Kombu.Pools (Kombu v0.1.0)

Connection, Channel, and Producer pools (kombu.pools).

Summary

Gets or creates a ConnectionPool for conn from the global connections group.

get_limit()

Returns the global pool limit (default 10).

producers(conn)

Gets or creates a ProducerPool for conn from the global producers group.

reset()

Closes all open resources and clears all global pool groups (kombu.pools.reset).

Updates the global pool limit and resizes all active pools (kombu.pools.set_limit).

@spec connections(Kombu.Connection.t()) :: Kombu.Pools.ConnectionPool.t()

Gets or creates a ConnectionPool for conn from the global connections group.

@spec get_limit() :: non_neg_integer()

Returns the global pool limit (default 10).

@spec producers(Kombu.Connection.t()) :: Kombu.Pools.ProducerPool.t()

Gets or creates a ProducerPool for conn from the global producers group.

@spec reset() :: :ok

Closes all open resources and clears all global pool groups (kombu.pools.reset).

@spec set_limit(non_neg_integer() | nil, keyword()) :: non_neg_integer()

Updates the global pool limit and resizes all active pools (kombu.pools.set_limit).