Skip to content

WIP: Add RabbitMQ helpers

Santiago Gil requested to merge santigl/rabbitmq/pika-helpers into master

Before raising this MR, consider whether the following are required, and complete if so:

  • Unit tests
  • [ ] Metrics
  • Documentation update(s)

If not required, please explain in brief why not.

Description

Note: this MR is replaced by !692 (merged), which uses pika's asynchronous SelectConnection adapter.

This MR adds methods that facilitate sending and consuming messages from RabbitMQ. They will wrap calls to the pika module and provide connection and error-handling for callers.

Changes proposed in this merge request:

  • Implement PikaConsumer and PikaPublisher classes
  • Adjust requirements, tox.ini, and CI to run tests using pika
  • TODO:
    • Add retry logic
      • Consumer
      • Publisher

Issues addressed

Addresses part of #341 (closed).

Edited by Santiago Gil

Merge request reports