Use proper channel.Consume() with a timeout, instead of timed retries.#17

Merged

marselester merged 22 commits intomarselester:mainfrom

roncemer:main

Jul 1, 2025

Commits on Jun 30, 2025

Update instructions for producer.py.
Ron Cemer
committed
Use proper channel.Consume() with a timeout.
Ron Cemer
committed
Trigger action.
Ron Cemer
committed
Remove temp file.
Ron Cemer
committed
Only create one Delivery per queue; keep them in a map by queue name.
Ron Cemer
committed
Only create one Delivery per queue; keep them in a map by queue name.
Ron Cemer
committed
Make delivery map when instantiating the struct.
Ron Cemer
committed
Move channel.Consume() to the Observe() function.
Ron Cemer
committed
Re-order assignments.
Ron Cemer
committed
Trigger pipeline.
Ron Cemer
committed
Remove temp file.
Ron Cemer
committed
Use newer rabbitmq image.
Ron Cemer
committed
Return any JSON encoding error.
Ron Cemer
committed

Commits on Jul 1, 2025

Copmletely initialize delivery_info before assigning to properties.
Ron Cemer
committed
Clean up delivery_info map.
Ron Cemer
committed
Add unit test for RabbitMQ broker.
Ron Cemer
committed
Increase test timeout.
Ron Cemer
committed
Fix messages disappearing.
Ron Cemer
committed
Fix lint.
Ron Cemer
committed
Fix lint.
Ron Cemer
committed
Fix lint.
Ron Cemer
committed
Fix unit tests.
Ron Cemer
committed