Description
As a dev, I want to implement a queue.Runtime which processes RabbitMQ messages concurrently, so that users of humus can implement their processor business logic and humus handles consuming and acknowledging the successfully processed messages.
Implementation notes
Acceptance Criteria
Related Issues
No response
Description
As a dev, I want to implement a
queue.Runtimewhich processes RabbitMQ messages concurrently, so that users of humus can implement their processor business logic and humus handles consuming and acknowledging the successfully processed messages.Implementation notes
queue/rabbitmqAtMostOnceRuntimeandAtLeastOnceRuntime.Acceptance Criteria
example/queue/rabbitmq-at-most-once. This example should come with a podman-compose.yaml which runs rabbitmqexample/queue/rabbitmq-at-least-once. This example should come with a podman-compose.yaml which runs rabbitmqqueue/rabbitmqqueue/rabbitmqpackage, types, and functions are documentedRelated Issues
No response