pkg/amqp/connection.go
Function newConnection
has 56 lines of code (exceeds 50 allowed). Consider refactoring. Open
Open
func newConnection(url string, config Config) (*Connection, error) {
// Extract our config into a streadway.Config
streadwayConfig := streadway.Config{
SASL: config.SASL,
Vhost: config.Vhost,