in sender/ConnectionPool.go [41:47]
func NewAmqpConnectionPool(conn mocks.AmqpConnectionInterface) AmqpConnectionPool { return &AmqpConnectionPoolImpl{ connection: conn, amqpWrapper: nil, mutex: sync.Mutex{}, } }