Skip to content

highmobility/off_broadway_amqp10

Repository files navigation

OffBroadwayAmqp10

Build Status Docs Hex.pm Version

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.