- Add support to AMQP 4.0
- Fix compilation warning around the use of
Logger.warn/2
. - Fix a bug with validating a behaviour when implementing multiple behaviours.
- Fix closing connection from channel pool (see #129).
- Add the
BroadwayRabbitMQ.ChannelPool
behaviour. - Add the
[:broadway_rabbitmq, :amqp, :connection_failure]
Telemetry event. - Bump Elixir requirement to 1.8+.
- Allow nimble_options 1.0+.
- Support nimble_options 0.4.0 alongside 0.3.x
- Add support to AMQP 3.0
- Add support to AMQP 2.0
- Require Broadway 1.0
-
Add support for a few Telemetry events. See the "Telemetry" section in the docs for
BroadwayRabbitMQ.Producer
. -
Add support for
:consume_options
when starting aBroadwayRabbitMQ.Producer
to pass options down toAMQP.Basic.consume/4
.
-
Bump nimble_options dependency to 0.3.5 which fixes some deprecation warnings.
-
Fix a few potential RabbitMQ issues like possible connection leaking (see #83).
- Start using nimble_options for validation. This has no practical consequences on the API but introduces a new dependency in broadway_rabbitmq (which was already used by Broadway).
- Raise if acking messages fails. See the discussion in dashbitco/broadway#208.
- Deprecate use of a default
:on_failure
option. - Expose always-present
:amqp_channel
metadata containing theAMQP.Channel
struct.
- Add support for the
:after_connect
option. - Add
auth_mechanisms
to the supported connection options for RabbitMQ. - Support passing in an AMQP connection name.
- Update Broadway requirement to
~> 0.6.0
(it was exactly0.6.0
) before.
- Update Broadway requirement to 0.6.0.
- Re-initialize client options on every reconnect. This means that the
:merge_options
function is called on every reconnect, allowing to do things such as round-robin on a list of RabbitMQ URLs. - Remove support for the deprecated
:requeue
option. Use:on_success
/:on_failure
instead. - Improve logging on RabbitMQ disconnections and reconnections.
- Add support for configuring acking behaviour using
:on_success
and:on_failure
options - Add support for declare options
:no_wait
and:arguments
- Handle
:auth_failure
,:unknown_host
and:socket_closed_unexpectedly
errors - Add support for a function as the
:connection
- Add support for
:merge_options
option - Update to Broadway v0.5.0
- Add
:declare
and:bindings
options to producers - Handle consumer cancellation by reconnecting
- Allow overriding
:buffer_size
and:buffer_keep
- Make
:buffer_size
required if:prefetch_count
is set to0
- Allow passing RabbitMQ connection options via an AMQP URI
- New option
:metadata
that allows users to select which metadata should be retrieved and appended to the message struct - New option
:requeue
that allows users to define a strategy for requeuing failed messages
- Initial release