Kombu.Pools.ConnectionPool (Kombu v0.1.0)

Copy Markdown View Source

Pool of %Kombu.Connection{} instances (kombu.connection.ConnectionPool).

Summary

Types

t()

Functions

acquire(connection_pool, opts \\ [])
acquire_channel(pool, opts \\ [], fun)
force_close_all(connection_pool, opts \\ [])
limit(connection_pool)
new(conn, opts \\ [])
release(connection_pool, conn)
replace(connection_pool, conn)
resize(connection_pool, limit, opts \\ [])
with_connection(connection_pool, opts \\ [], fun)

Types

t()

@type t() :: %Kombu.Pools.ConnectionPool{connection: term(), resource: term()}

Functions

acquire(connection_pool, opts \\ [])

acquire_channel(pool, opts \\ [], fun)

force_close_all(connection_pool, opts \\ [])

limit(connection_pool)

new(conn, opts \\ [])

release(connection_pool, conn)

replace(connection_pool, conn)

resize(connection_pool, limit, opts \\ [])

with_connection(connection_pool, opts \\ [], fun)