Skip to content

Latest commit

 

History

History
24 lines (17 loc) · 1.06 KB

Changelog.md

File metadata and controls

24 lines (17 loc) · 1.06 KB
Raw

Changelog

v0.1.1 - Patch

Released unreleased

  • Emitting off_broadway_emqtt.receive_message.ack reads message topic from message receipt instead of from the message body. This ensures that topic is included in telemetry events even if the message has been altered during dispatch.
  • Move emqtt.start_link/1 and emqtt.connect/1 to a handle_continue/2 callback to prevent blocking GenServer.init/1.
  • Convert host and server_name_indication to charlist when validating options.
  • Return new state from handle_continue on connection error.

v0.1.0 - Initial release

Released 2024-09-24

The initial release supports connecting to an MQTT broker using emqtt, and consume messages using a Broadway pipeline.

Supported features

  • Support most emqtt configurable options as producer config options.
  • Specify buffer size and overflow strategy for the ets table buffer.
  • OffBroadway.EMQTT.MessageHandler behaviour to support overriding default implementation.
  • Telemetry events for observability.