WIP: Add RabbitMQ helpers
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
andPikaPublisher
classes - Adjust requirements,
tox.ini
, and CI to run tests usingpika
- TODO:
- Add retry logic
-
Consumer -
Publisher
-
- Add retry logic
Issues addressed
Addresses part of #341 (closed).
Edited by Santiago Gil