fix(connection): fix passing dial cfg

heureka · Jul 7, 2023 · e4a4d82 · e4a4d82
1 parent ffa9c02
commit e4a4d82
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/connection/connection.go b/connection/connection.go
@@ -34,7 +34,7 @@ func Dial(url string, ops ...Option) (*Redialer, error) {
 		op(&r)
 	}
 
-	if err := r.dial(amqp.Config{}); err != nil {
+	if err := r.dial(r.cfg); err != nil {
 		return nil, fmt.Errorf("dial: %w", err)
 	}