ex_rabbit_pool v1.0.2 ExRabbitPool.Consumer behaviour View Source

Link to this section Summary

Link to this section Types

Link to this section Callbacks

Link to this callback

basic_cancel(arg1, arg2, no_wait) View Source
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(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(ExRabbitPool.Consumer.State.t(), AMQP.Basic.consumer_tag()) ::
  :ok | {:stop, reason()}

Link to this callback

basic_deliver(arg1, arg2, meta) View Source
basic_deliver(ExRabbitPool.Consumer.State.t(), AMQP.Basic.payload(), meta()) ::
  :ok | {:stop, reason()}