add support func NewConnector

devimteam · Oct 25, 2018 · 1f7b27a · 1f7b27a
1 parent 76d4e0e
commit 1f7b27a
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
+	}
+}