Kombu.Pools.ChannelPool (Kombu v0.1.0)

Copy Markdown View Source

Pool of channels (kombu.connection.ChannelPool).

Summary

Types

t()

Functions

acquire(channel_pool, opts \\ [])
force_close_all(channel_pool, opts \\ [])
limit(channel_pool)
new(conn, opts \\ [])
release(channel_pool, ch)
replace(channel_pool, ch)
resize(channel_pool, limit, opts \\ [])
with_channel(channel_pool, opts \\ [], fun)

Types

t()

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

Functions

acquire(channel_pool, opts \\ [])

force_close_all(channel_pool, opts \\ [])

limit(channel_pool)

new(conn, opts \\ [])

release(channel_pool, ch)

replace(channel_pool, ch)

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

with_channel(channel_pool, opts \\ [], fun)