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 /plugins/jobs/brokers/amqp/item.go | |
| 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 'plugins/jobs/brokers/amqp/item.go')
| -rw-r--r-- | plugins/jobs/brokers/amqp/item.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/plugins/jobs/brokers/amqp/item.go b/plugins/jobs/brokers/amqp/item.go index 7f1bf204..4751df58 100644 --- a/plugins/jobs/brokers/amqp/item.go +++ b/plugins/jobs/brokers/amqp/item.go @@ -16,7 +16,7 @@ func From(d amqp.Delivery) *Item { } type Item struct { - // Job contains name of job broker (usually PHP class). + // Job contains pluginName of job broker (usually PHP class). Job string `json:"job"` // Ident is unique identifier of the job, should be provided from outside |