diff --git a/queue/other/deliver_message.go b/queue/other/deliver_message.go deleted file mode 100644 index 18ec2f2..0000000 --- a/queue/other/deliver_message.go +++ /dev/null @@ -1,32 +0,0 @@ -/* - * Copyright (c) 2024 OrigAdmin. All rights reserved. - */ - -package other - -import ( - "context" - - "github.com/nsqio/go-nsq" - - "github.com/origadmin/toolkits/queue" -) - -type deliverMessage struct { - message *queue.Message - nsqMsg *nsq.Message -} - -func (d deliverMessage) Message() *queue.Message { - return d.message -} - -func (d deliverMessage) Ack(ctx context.Context) error { - d.nsqMsg.Finish() - return nil -} - -func (d deliverMessage) Nack(ctx context.Context) error { - d.nsqMsg.Requeue(0) - return nil -}