Skip to content

v0.2.0

Choose a tag to compare

View all tags
@spumer spumer released this 03 Oct 11:06
· 34 commits to master since this release
v0.2.0
d62f9ac

v0.2.0 (2024-10-03)

Feat

  • KombuBroker: now RabbitMQ return error when message published to non-existing queue, previously the message was discarded; (use mandatory=True) (Closes #3)
  • KombuBroker: now you can ensure .XQ and .DQ queues when canonical declared before. Just place queue name to broker.queues_pending and call declare with ensure=True

Fix

  • KombuBroker: do not close channels each time, use channel context manager instead (all channels are support our ReleasableChannel protocol)
  • topology: now declare_*_queue re-raise PreconditionFailed when it's not topology difference error (e.g. invalid arguments)
  • topology: x-message-ttl now passed correclty (previous we can pass float instead int; rabbitmq not allow float)
  • deps: update to kombu-pyamqp-threadsafe>=0.4.1 (Closes #2)

Refactor

  • broker: add _enqueue_message function; now enqueue can be overrided or reused internally
  • explicit use canonical queue name where it required; use queue names from given Topology

Full Changelog: v0.1.1...v0.2.0

Assets 2
Loading