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 <[email protected]>

1 files changed, 4 insertions, 2 deletions

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
 }