diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-10 01:18:56 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-10 01:18:56 +0300 |
| commit | 4fcb5979fad87f6e268f5b9df91ee2ee91e9ef16 (patch) | |
| tree | 30ed85120f8a39fd07756af9f5ce3422cf318971 /.github | |
| parent | 4566f88004e81d3229222d82614c15346ac2e47d (diff) | |
AMQP job driver...
Update main driver's interface, add Consume(*pipeline) method. Implement
it on the amqp and ephemeral drivers.
Fix error with incorrect order of Register <-> Consume method calls.
Implement rabbitMQ driver, add timeouts, dead-letter-exchange,
packing-unpacking of the amqp messages.
Implement AMQP redialer in case of network error as well as channels
re-creation.
Update drawio diagram.
Update .rr.yaml jobs configuration, add all amqp options. Implement
Ack/Nack.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to '.github')
0 files changed, 0 insertions, 0 deletions