remove extraneous connect() call (#344)

This commit is contained in:
Michael Quigley 2023-06-16 11:39:55 -04:00
parent dc3648f73d
commit 0e91c2687f
No known key found for this signature in database
GPG Key ID: 9B60314A9DD20A62

View File

@ -47,9 +47,6 @@ func newAmqpSource(cfg *AmqpSourceConfig) (*amqpSource, error) {
close: make(chan struct{}),
join: make(chan struct{}),
}
if err := as.connect(); err != nil {
return nil, err
}
return as, nil
}