Merge remote-tracking branch 'origin/master'

devimteam · Nov 17, 2018 · 09e28e2 · 09e28e2
2 parents 3f21cf5 + 1f7b27a
commit 09e28e2
Showing 1 changed file with 6 additions and 0 deletions.
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
+	}
+}