fix(nats): default addr

appleboy · appleboy · commit 8dfa454c5eb4 · 2021-08-01T20:47:30.000+08:00
Signed-off-by: Bo-Yi Wu &lt;appleboy.tw@gmail.com&gt;
diff --git a/nats/nats.go b/nats/nats.go
@@ -69,7 +69,7 @@ func WithLogger(l queue.Logger) Option {
 func NewWorker(opts ...Option) *Worker {
 	var err error
 	w := &Worker{
-		addr:  "nats://127.0.0.1:4222",
+		addr:  "127.0.0.1:4222",
 		subj:  "foobar",
 		queue: "foobar",
 		stop:  make(chan struct{}),
