ex_rabbit_pool

v1.0.2

ex_rabbit_pool v1.0.2 ExRabbitPool.Consumer.State View Source

RabbitMQ Consumer Worker State.

State attributes:

  • :pool_id - the name of the connection pool to RabbitMQ
  • :channel - the RabbitMQ channel for consuming new messages
  • :monitor - a monitor for handling channel crashes
  • :queue - the name of the queue to consume
  • :consumer_tag - the consumer tag assigned by RabbitMQ
  • :config - the consumer configuration attributes
  • :adapter - the RabbitMQ client to use

Link to this section Summary

Types

t()

Consumer State Type

Link to this section Types

Link to this type

t() View Source 
t() :: %ExRabbitPool.Consumer.State{
  adapter: module(),
  caller: term(),
  channel: AMQP.Channel.t(),
  config: keyword(),
  consumer_tag: AMQP.Basic.consumer_tag(),
  monitor: reference(),
  pool_id: atom(),
  queue: AMQP.Basic.queue()
}

Consumer State Type