Merge remote-tracking branch 'origin/master'

vetcher · vetcher · commit 09e28e232220 · 2018-11-17T16:42:32.000+03:00
diff --git a/conn/dialers.go b/conn/dialers.go
@@ -95,3 +95,9 @@ func ConfigConnector(url string, config amqp.Config, opts ...ConnectionOption) C
 		return DialConfig(url, config, opts...)
 	}
 }
+
+func NewConnector(url string, opts ...ConnectionOption) Connector {
+	return func() (*Connection, error) {
+		return Connect(url, opts...), nil
+	}
+}

Original file line number	Diff line number	Diff line change
`@@ -95,3 +95,9 @@ func ConfigConnector(url string, config amqp.Config, opts ...ConnectionOption) C`
`95`	`95`	`return DialConfig(url, config, opts...)`
`96`	`96`	`}`
`97`	`97`	`}`
	`98`	`+`
	`99`	`+func NewConnector(url string, opts ...ConnectionOption) Connector {`
	`100`	`+ return func() (*Connection, error) {`
	`101`	`+ return Connect(url, opts...), nil`
	`102`	`+ }`
	`103`	`+}`