ex_rabbit_pool v1.0.2 ExRabbitPool.Consumer behaviour View Source
Link to this section Summary
Link to this section Types
Link to this type
meta()
View Source
meta()
View Source
meta() :: map()
meta() :: map()
Link to this type
no_wait()
View Source
no_wait()
View Source
no_wait() :: boolean()
no_wait() :: boolean()
Link to this type
reason()
View Source
reason()
View Source
reason() :: any()
reason() :: any()
Link to this section Callbacks
Link to this callback
basic_cancel(arg1, arg2, no_wait)
View Source
basic_cancel(arg1, arg2, no_wait)
View Source
basic_cancel(
ExRabbitPool.Consumer.State.t(),
AMQP.Basic.consumer_tag(),
no_wait()
) :: :ok | {:stop, reason()}
basic_cancel( ExRabbitPool.Consumer.State.t(), AMQP.Basic.consumer_tag(), no_wait() ) :: :ok | {:stop, reason()}
Link to this callback
basic_cancel_ok(arg1, arg2)
View Source
basic_cancel_ok(arg1, arg2)
View Source
basic_cancel_ok(ExRabbitPool.Consumer.State.t(), AMQP.Basic.consumer_tag()) ::
:ok | {:stop, reason()}
basic_cancel_ok(ExRabbitPool.Consumer.State.t(), AMQP.Basic.consumer_tag()) :: :ok | {:stop, reason()}
Link to this callback
basic_consume_ok(arg1, arg2)
View Source
basic_consume_ok(arg1, arg2)
View Source
basic_consume_ok(ExRabbitPool.Consumer.State.t(), AMQP.Basic.consumer_tag()) ::
:ok | {:stop, reason()}
basic_consume_ok(ExRabbitPool.Consumer.State.t(), AMQP.Basic.consumer_tag()) :: :ok | {:stop, reason()}
Link to this callback
basic_deliver(arg1, arg2, meta)
View Source
basic_deliver(arg1, arg2, meta)
View Source
basic_deliver(ExRabbitPool.Consumer.State.t(), AMQP.Basic.payload(), meta()) ::
:ok | {:stop, reason()}
basic_deliver(ExRabbitPool.Consumer.State.t(), AMQP.Basic.payload(), meta()) :: :ok | {:stop, reason()}