diff options
| -rw-r--r-- | priority_queue/binary_heap_test.go | 12 | ||||
| -rw-r--r-- | priority_queue/interface.go | 9 |
2 files changed, 0 insertions, 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 } |