Channel configuration

The following keys are supported:

• role: channel role (atom), allowed values are:

  • :consumer: Receives messages from the channel via Lapin.Connection callbacks
  • :producer: Can publish messages to che channel
  • :passive: Used to declare channel configuration, can’t receive nor publish
• pattern: channel pattern (module using the Lapin.Pattern behaviour)
• exchange: broker exchange (String.t)
• queue: broker queue (String.t)

If using the Lapin.Pattern.Config default implementation, the following keys are also supported:

• consumer_ack: send consumer ack (boolean), default: false
• consumer_prefetch cosumer prefetch (integer | nil), default: nil
• exchange_type: declare type of the exchange (:direct, :fanout, :topic), default: :direct
• exchange_durable: declare exchange as durable (boolean), default: true
• publisher_confirm: expect RabbitMQ publish confirms (boolean), default: false
• publisher_mandatory: messages published as mandatory by default (boolean), deafault: false
• publisher_persistent: messages published as persistent by default (boolean), deafault: false
• queue_arguments: queue arguments (list of {string, type, value}), default: []
• queue_durable: declare queue as durable (boolean), default: true
• routing_key: routing_key for bindings (string), default: “”

Consumer Prefetch

Consumer Tag

Exchange name

Queue name

Queue Arguments

Channel role

Routing key