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]>

2 files changed, 6 insertions, 4 deletions

diff --git a/pkg/priorityqueue/binary_heap_test.go b/pkg/priorityqueue/binary_heap_test.go
index 6be6a99d..06d0735c 100644
--- a/pkg/priorityqueue/binary_heap_test.go
+++ b/pkg/priorityqueue/binary_heap_test.go
@@ -12,10 +12,12 @@ import (
 
 type Test int
 
-func (t Test) Ack() {
+func (t Test) Ack() error {
+	return nil
 }
 
-func (t Test) Nack() {
+func (t Test) Nack() error {
+	return nil
 }
 
 func (t Test) Body() []byte {
diff --git a/pkg/priorityqueue/interface.go b/pkg/priorityqueue/interface.go
index 7c053e6d..8278dc8d 100644
--- a/pkg/priorityqueue/interface.go
+++ b/pkg/priorityqueue/interface.go
@@ -21,8 +21,8 @@ type Item interface {
 	Context() ([]byte, error)
 
 	// Ack - acknowledge the Item after processing
-	Ack()
+	Ack() error
 
 	// Nack - discard the Item
-	Nack()
+	Nack() error
 }