refactor: simplify return error

appleboy · appleboy · commit 3f9a6f4df159 · 2022-04-03T21:44:45.000+08:00
diff --git a/nsq.go b/nsq.go
@@ -183,12 +183,7 @@ func (w *Worker) Queue(job queue.QueuedMessage) error {
 		return queue.ErrQueueShutdown
 	}
 
-	err := w.p.Publish(w.opts.topic, job.Bytes())
-	if err != nil {
-		return err
-	}
-
-	return nil
+	return w.p.Publish(w.opts.topic, job.Bytes())
 }
 
 // Request fetch new task from queue

Original file line number	Diff line number	Diff line change
`@@ -183,12 +183,7 @@ func (w *Worker) Queue(job queue.QueuedMessage) error {`
`183`	`183`	`return queue.ErrQueueShutdown`
`184`	`184`	`}`
`185`	`185`
`186`		`- err := w.p.Publish(w.opts.topic, job.Bytes())`
`187`		`- if err != nil {`
`188`		`- return err`
`189`		`- }`
`190`		`-`
`191`		`- return nil`
	`186`	`+ return w.p.Publish(w.opts.topic, job.Bytes())`
`192`	`187`	`}`
`193`	`188`
`194`	`189`	`// Request fetch new task from queue`