From 4566f88004e81d3229222d82614c15346ac2e47d Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Thu, 8 Jul 2021 17:54:29 +0300 Subject: AMQP update... Add redialer, consumer, rabbit queues initializer. Update configuration (.rr.yaml). Add ack/nack for the jobs main plugin with error handling. Add Qos, queues bining and declaration. Signed-off-by: Valery Piashchynski --- plugins/jobs/brokers/ephemeral/item.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'plugins/jobs/brokers/ephemeral/item.go') diff --git a/plugins/jobs/brokers/ephemeral/item.go b/plugins/jobs/brokers/ephemeral/item.go index 40c6b3e4..76e83d00 100644 --- a/plugins/jobs/brokers/ephemeral/item.go +++ b/plugins/jobs/brokers/ephemeral/item.go @@ -118,10 +118,12 @@ func (j *Item) Context() ([]byte, error) { return ctx, nil } -func (j *Item) Ack() { +func (j *Item) Ack() error { // noop for the in-memory + return nil } -func (j *Item) Nack() { +func (j *Item) Nack() error { // noop for the in-memory + return nil } -- cgit v1.2.3