From 9de85482ce19c4e40b68d9e3f6458875856a071e Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Thu, 14 Oct 2021 16:26:52 +0300 Subject: - Remove Acknowledgement from the PQ interface Signed-off-by: Valery Piashchynski --- priority_queue/binary_heap_test.go | 12 ------------ priority_queue/interface.go | 9 --------- 2 files changed, 21 deletions(-) diff --git a/priority_queue/binary_heap_test.go b/priority_queue/binary_heap_test.go index 2eed34e6..e29835c2 100644 --- a/priority_queue/binary_heap_test.go +++ b/priority_queue/binary_heap_test.go @@ -12,18 +12,6 @@ import ( type Test int -func (t Test) Ack() error { - return nil -} - -func (t Test) Nack() error { - return nil -} - -func (t Test) Requeue(_ map[string][]string, _ int64) error { - return nil -} - func (t Test) Body() []byte { return nil } diff --git a/priority_queue/interface.go b/priority_queue/interface.go index 9efa4652..42510f96 100644 --- a/priority_queue/interface.go +++ b/priority_queue/interface.go @@ -19,13 +19,4 @@ type Item interface { // Context is the Item meta information Context() ([]byte, error) - - // Ack - acknowledge the Item after processing - Ack() error - - // Nack - discard the Item - Nack() error - - // Requeue - put the message back to the queue with the optional delay - Requeue(headers map[string][]string, delay int64) error } -- cgit v1.2.3