OffBroadwayAmqp10

An AMQP 1.0 connector for Broadway.

Installation

The package can be installed by adding off_broadway_amqp10 to your list of dependencies in mix.exs:

def deps do
  [
    {:off_broadway_amqp10, "~> 0.1.1"}
  ]
end

TODO

• Handle connection errors
• Handle session errors
• Backoff strategy to re-connect in case of an error
• Handle body type: [#'v1_0.amqp_sequence'{}] specified in this doc and this PR.