diff --git a/connection/connection.go b/connection/connection.go index f33c6db..f2e9823 100644 --- 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) }