Kombu.Pools.ProducerPool (Kombu v0.1.0)

Copy Markdown View Source

Pool of %Kombu.Producer{} instances (kombu.pools.ProducerPool).

Summary

Types

t()

Functions

acquire(producer_pool, opts \\ [])
force_close_all(producer_pool, opts \\ [])
limit(producer_pool)
new(connections_or_conn, opts \\ [])
release(producer_pool, prod)
resize(producer_pool, limit, opts \\ [])
with_producer(producer_pool, opts \\ [], fun)

Types

t()

@type t() :: %Kombu.Pools.ProducerPool{connections: term(), resource: term()}

Functions

acquire(producer_pool, opts \\ [])

force_close_all(producer_pool, opts \\ [])

limit(producer_pool)

new(connections_or_conn, opts \\ [])

release(producer_pool, prod)

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

with_producer(producer_pool, opts \\ [], fun)