V1.4.0

HareMq 1.4.0 Release Notes

New features

• Stream queue support

  • Added stream-aware consumer/publisher mode.
  • stream: true consumption.
  • stream_offset support: "first", "last", "next" (default), integer, %DateTime{}.
  • Added stream integration tests.

• Retry/delay improvements

  • Added delay_cascade_in_ms config field:
    • List of per-retry delays, e.g. [1_000, 5_000, 30_000].
    • Allows granular retry delay schedules in addition to delay_in_ms.
  • Configuration normalized:
    • check_interval -> check_interval_ms
    • message_ttl -> message_ttl_ms

• AutoScaler / DynamicSupervisor improvements

  • Better dynamic scaling decisions.
  • Configurable worker call timeout.
  • Improved auto-scaler logging and error diagnostics.

• Consumer worker robustness

  • In-flight task tracking and drain handling.
  • Connection/channel monitor handling improved.

Stability improvements

• wait_for_messages default timeout changed from 5_000 to 10_000.
• wait_for_consumers default timeout changed from 5_000 to 10_000.
• Reduced slow/CI flakiness for RabbitMQ integration tests.

Bug fixes

• Fixed consumer_worker drain test variable warning.
• Fixed queue/exchange declaration behavior in consumers.
• Fixed JSON encoding errors in publisher payload handling.
• Fixed nil delay_in_ms / retry_limit handling in configuration.
• Fixed reconnect/consumer channel error logging and recovery paths.

Full Changelog: v1.3.0...v1.4.0