chore: update error message format.

appleboy · appleboy · commit 0447790c9746 · 2022-06-27T10:24:06.000+08:00
diff --git a/rabbitmq.go b/rabbitmq.go
@@ -38,12 +38,12 @@ func NewWorker(opts ...Option) *Worker {
 
 	w.conn, err = amqp.Dial(w.opts.addr)
 	if err != nil {
-		panic(err)
+		w.opts.logger.Fatal("can't connect rabbitmq:", err)
 	}
 
 	w.channel, err = w.conn.Channel()
 	if err != nil {
-		panic(err)
+		w.opts.logger.Fatal("can't setup channel:", err)
 	}
 
 	if err := w.channel.ExchangeDeclare(
@@ -55,7 +55,7 @@ func NewWorker(opts ...Option) *Worker {
 		false,               // noWait
 		nil,                 // arguments
 	); err != nil {
-		panic(err)
+		w.opts.logger.Fatal("can't declares an exchange:", err)
 	}
 
 	return w

Original file line number	Diff line number	Diff line change
`@@ -38,12 +38,12 @@ func NewWorker(opts ...Option) *Worker {`
`38`	`38`
`39`	`39`	`w.conn, err = amqp.Dial(w.opts.addr)`
`40`	`40`	`if err != nil {`
`41`		`- panic(err)`
	`41`	`+ w.opts.logger.Fatal("can't connect rabbitmq:", err)`
`42`	`42`	`}`
`43`	`43`
`44`	`44`	`w.channel, err = w.conn.Channel()`
`45`	`45`	`if err != nil {`
`46`		`- panic(err)`
	`46`	`+ w.opts.logger.Fatal("can't setup channel:", err)`
`47`	`47`	`}`
`48`	`48`
`49`	`49`	`if err := w.channel.ExchangeDeclare(`
`@@ -55,7 +55,7 @@ func NewWorker(opts ...Option) *Worker {`
`55`	`55`	`false, // noWait`
`56`	`56`	`nil, // arguments`
`57`	`57`	`); err != nil {`
`58`		`- panic(err)`
	`58`	`+ w.opts.logger.Fatal("can't declares an exchange:", err)`
`59`	`59`	`}`
`60`	`60`
`61`	`61`	`return w`