fix: wrong AMQP scheme

appleboy · appleboy · commit 86be7ce3eb26 · 2022-06-30T10:36:41.000+08:00
diff --git a/options.go b/options.go
@@ -47,7 +47,7 @@ type options struct {
 // WithAddr setup the URI
 func WithAddr(addr string) Option {
 	return func(w *options) {
-		w.addr = "nats://" + addr
+		w.addr = addr
 	}
 }
 

Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ type options struct {`
`47`	`47`	`// WithAddr setup the URI`
`48`	`48`	`func WithAddr(addr string) Option {`
`49`	`49`	`return func(w *options) {`
`50`		`- w.addr = "nats://" + addr`
	`50`	`+ w.addr = addr`
`51`	`51`	`}`
`52`	`52`	`}`
`53`	`53`