diff --git a/src/DotNetCore.CAP.PostgreSql/DotNetCore.CAP.PostgreSql.csproj b/src/DotNetCore.CAP.PostgreSql/DotNetCore.CAP.PostgreSql.csproj
index 237db79..51eb932 100644
--- a/src/DotNetCore.CAP.PostgreSql/DotNetCore.CAP.PostgreSql.csproj
+++ b/src/DotNetCore.CAP.PostgreSql/DotNetCore.CAP.PostgreSql.csproj
@@ -9,7 +9,6 @@
   <PropertyGroup>
     <DocumentationFile>bin\$(Configuration)\netstandard2.0\DotNetCore.CAP.PostgreSql.xml</DocumentationFile>
     <NoWarn>1701;1702;1705;CS1591</NoWarn>
-    <LangVersion>8</LangVersion>
   </PropertyGroup>
   
   <ItemGroup>
diff --git a/src/DotNetCore.CAP.PostgreSql/IDataStorage.PostgreSql.cs b/src/DotNetCore.CAP.PostgreSql/IDataStorage.PostgreSql.cs
index bfb02d8..0c37114 100644
--- a/src/DotNetCore.CAP.PostgreSql/IDataStorage.PostgreSql.cs
+++ b/src/DotNetCore.CAP.PostgreSql/IDataStorage.PostgreSql.cs
@@ -42,7 +42,7 @@ namespace DotNetCore.CAP.PostgreSql
         {
             var sql =
                 $"UPDATE {_pubName} SET \"Retries\"=@Retries,\"ExpiresAt\"=@ExpiresAt,\"StatusName\"=@StatusName WHERE \"Id\"=@Id";
-            await using var connection = new NpgsqlConnection(_options.Value.ConnectionString);
+            using var connection = new NpgsqlConnection(_options.Value.ConnectionString);
             await connection.ExecuteAsync(sql, new
             {
                 Id = long.Parse(message.DbId),
@@ -56,7 +56,7 @@ namespace DotNetCore.CAP.PostgreSql
         {
             var sql =
                 $"UPDATE {_recName} SET \"Retries\"=@Retries,\"ExpiresAt\"=@ExpiresAt,\"StatusName\"=@StatusName WHERE \"Id\"=@Id";
-            await using var connection = new NpgsqlConnection(_options.Value.ConnectionString);
+            using var connection = new NpgsqlConnection(_options.Value.ConnectionString);
             await connection.ExecuteAsync(sql, new
             {
                 Id = long.Parse(message.DbId),
@@ -164,7 +164,7 @@ namespace DotNetCore.CAP.PostgreSql
         public async Task<int> DeleteExpiresAsync(string table, DateTime timeout, int batchCount = 1000,
             CancellationToken token = default)
         {
-            await using var connection = new NpgsqlConnection(_options.Value.ConnectionString);
+            using var connection = new NpgsqlConnection(_options.Value.ConnectionString);
 
             return await connection.ExecuteAsync(
                 $"DELETE FROM {table} WHERE \"ExpiresAt\" < @timeout AND \"Id\" IN (SELECT \"Id\" FROM {table} LIMIT @batchCount);",
@@ -178,7 +178,7 @@ namespace DotNetCore.CAP.PostgreSql
                 $"SELECT * FROM {_pubName} WHERE \"Retries\"<{_capOptions.Value.FailedRetryCount} AND \"Version\"='{_capOptions.Value.Version}' AND \"Added\"<'{fourMinAgo}' AND (\"StatusName\"='{StatusName.Failed}' OR \"StatusName\"='{StatusName.Scheduled}') LIMIT 200;";
 
             var result = new List<MediumMessage>();
-            await using var connection = new NpgsqlConnection(_options.Value.ConnectionString);
+            using var connection = new NpgsqlConnection(_options.Value.ConnectionString);
             var reader = await connection.ExecuteReaderAsync(sql);
             while (reader.Read())
             {
@@ -202,7 +202,7 @@ namespace DotNetCore.CAP.PostgreSql
 
             var result = new List<MediumMessage>();
 
-            await using var connection = new NpgsqlConnection(_options.Value.ConnectionString);
+            using var connection = new NpgsqlConnection(_options.Value.ConnectionString);
             var reader = await connection.ExecuteReaderAsync(sql);
             while (reader.Read())
             {
diff --git a/src/DotNetCore.CAP.PostgreSql/IMonitoringApi.PostgreSql.cs b/src/DotNetCore.CAP.PostgreSql/IMonitoringApi.PostgreSql.cs
index 56e5619..e41529c 100644
--- a/src/DotNetCore.CAP.PostgreSql/IMonitoringApi.PostgreSql.cs
+++ b/src/DotNetCore.CAP.PostgreSql/IMonitoringApi.PostgreSql.cs
@@ -34,7 +34,7 @@ namespace DotNetCore.CAP.PostgreSql
             var sql =
                 $"SELECT * FROM {_pubName} WHERE \"Id\"={id} FOR UPDATE SKIP LOCKED";
 
-            await using var connection = new NpgsqlConnection(_options.Value.ConnectionString);
+            using var connection = new NpgsqlConnection(_options.Value.ConnectionString);
             return await connection.QueryFirstOrDefaultAsync<MediumMessage>(sql);
         }
 
@@ -42,7 +42,7 @@ namespace DotNetCore.CAP.PostgreSql
         {
             var sql =
                 $"SELECT * FROM {_recName} WHERE \"Id\"={id} FOR UPDATE SKIP LOCKED";
-            await using var connection = new NpgsqlConnection(_options.Value.ConnectionString);
+            using var connection = new NpgsqlConnection(_options.Value.ConnectionString);
             return await connection.QueryFirstOrDefaultAsync<MediumMessage>(sql);
         }
 
diff --git a/src/DotNetCore.CAP.PostgreSql/IStorageInitializer.PostgreSql.cs b/src/DotNetCore.CAP.PostgreSql/IStorageInitializer.PostgreSql.cs
index f8e8ba0..a9528c5 100644
--- a/src/DotNetCore.CAP.PostgreSql/IStorageInitializer.PostgreSql.cs
+++ b/src/DotNetCore.CAP.PostgreSql/IStorageInitializer.PostgreSql.cs
@@ -39,7 +39,7 @@ namespace DotNetCore.CAP.PostgreSql
             if (cancellationToken.IsCancellationRequested) return;
 
             var sql = CreateDbTablesScript(_options.Value.Schema);
-            await using (var connection = new NpgsqlConnection(_options.Value.ConnectionString))
+            using (var connection = new NpgsqlConnection(_options.Value.ConnectionString))
             {
                 await connection.ExecuteAsync(sql);
             }
diff --git a/src/DotNetCore.CAP.SqlServer/DotNetCore.CAP.SqlServer.csproj b/src/DotNetCore.CAP.SqlServer/DotNetCore.CAP.SqlServer.csproj
index b220951..1503ffe 100644
--- a/src/DotNetCore.CAP.SqlServer/DotNetCore.CAP.SqlServer.csproj
+++ b/src/DotNetCore.CAP.SqlServer/DotNetCore.CAP.SqlServer.csproj
@@ -10,7 +10,6 @@
   <PropertyGroup>
     <DocumentationFile>bin\$(Configuration)\netstandard2.0\DotNetCore.CAP.SqlServer.xml</DocumentationFile>
     <NoWarn>1701;1702;1705;CS1591</NoWarn>
-    <LangVersion>8</LangVersion>
   </PropertyGroup>
 
   <ItemGroup>
diff --git a/src/DotNetCore.CAP.SqlServer/IDataStorage.SqlServer.cs b/src/DotNetCore.CAP.SqlServer/IDataStorage.SqlServer.cs
index 7df2ea9..35290e4 100644
--- a/src/DotNetCore.CAP.SqlServer/IDataStorage.SqlServer.cs
+++ b/src/DotNetCore.CAP.SqlServer/IDataStorage.SqlServer.cs
@@ -42,7 +42,7 @@ namespace DotNetCore.CAP.SqlServer
         {
             var sql =
                 $"UPDATE {_pubName} SET Retries=@Retries,ExpiresAt=@ExpiresAt,StatusName=@StatusName WHERE Id=@Id";
-            await using var connection = new SqlConnection(_options.Value.ConnectionString);
+            using var connection = new SqlConnection(_options.Value.ConnectionString);
             await connection.ExecuteAsync(sql, new
             {
                 Id = message.DbId,
@@ -56,7 +56,7 @@ namespace DotNetCore.CAP.SqlServer
         {
             var sql =
                 $"UPDATE {_recName} SET Retries=@Retries,ExpiresAt=@ExpiresAt,StatusName=@StatusName WHERE Id=@Id";
-            await using var connection = new SqlConnection(_options.Value.ConnectionString);
+            using var connection = new SqlConnection(_options.Value.ConnectionString);
             await connection.ExecuteAsync(sql, new
             {
                 Id = message.DbId,
@@ -163,7 +163,7 @@ namespace DotNetCore.CAP.SqlServer
         public async Task<int> DeleteExpiresAsync(string table, DateTime timeout, int batchCount = 1000,
             CancellationToken token = default)
         {
-            await using var connection = new SqlConnection(_options.Value.ConnectionString);
+            using var connection = new SqlConnection(_options.Value.ConnectionString);
             return await connection.ExecuteAsync(
                 $"DELETE TOP (@batchCount) FROM {table} WITH (readpast) WHERE ExpiresAt < @timeout;",
                 new { timeout, batchCount });
@@ -176,7 +176,7 @@ namespace DotNetCore.CAP.SqlServer
                       $"AND Version='{_capOptions.Value.Version}' AND Added<'{fourMinAgo}' AND (StatusName = '{StatusName.Failed}' OR StatusName = '{StatusName.Scheduled}')";
 
             var result = new List<MediumMessage>();
-            await using var connection = new SqlConnection(_options.Value.ConnectionString);
+            using var connection = new SqlConnection(_options.Value.ConnectionString);
             var reader = await connection.ExecuteReaderAsync(sql);
             while (reader.Read())
             {
@@ -201,7 +201,7 @@ namespace DotNetCore.CAP.SqlServer
 
             var result = new List<MediumMessage>();
 
-            await using var connection = new SqlConnection(_options.Value.ConnectionString);
+            var connection = new SqlConnection(_options.Value.ConnectionString);
             var reader = await connection.ExecuteReaderAsync(sql);
             while (reader.Read())
             {
diff --git a/src/DotNetCore.CAP.SqlServer/IMonitoringApi.SqlServer.cs b/src/DotNetCore.CAP.SqlServer/IMonitoringApi.SqlServer.cs
index 9daf00d..16c7222 100644
--- a/src/DotNetCore.CAP.SqlServer/IMonitoringApi.SqlServer.cs
+++ b/src/DotNetCore.CAP.SqlServer/IMonitoringApi.SqlServer.cs
@@ -125,14 +125,14 @@ select count(Id) from {_recName} with (nolock) where StatusName = N'Failed';";
         public async Task<MediumMessage> GetPublishedMessageAsync(long id)
         {
             var sql = $@"SELECT * FROM {_pubName} WITH (readpast) WHERE Id={id}";
-            await using var connection = new SqlConnection(_options.ConnectionString);
+            using var connection = new SqlConnection(_options.ConnectionString);
             return await connection.QueryFirstOrDefaultAsync<MediumMessage>(sql);
         }
 
         public async Task<MediumMessage> GetReceivedMessageAsync(long id)
         {
             var sql = $@"SELECT * FROM {_recName} WITH (readpast) WHERE Id={id}";
-            await using var connection = new SqlConnection(_options.ConnectionString);
+            using var connection = new SqlConnection(_options.ConnectionString);
             return await connection.QueryFirstOrDefaultAsync<MediumMessage>(sql);
         }
 
diff --git a/src/DotNetCore.CAP.SqlServer/IStorageInitializer.SqlServer.cs b/src/DotNetCore.CAP.SqlServer/IStorageInitializer.SqlServer.cs
index 8c0e7c7..7e48127 100644
--- a/src/DotNetCore.CAP.SqlServer/IStorageInitializer.SqlServer.cs
+++ b/src/DotNetCore.CAP.SqlServer/IStorageInitializer.SqlServer.cs
@@ -39,7 +39,7 @@ namespace DotNetCore.CAP.SqlServer
             if (cancellationToken.IsCancellationRequested) return;
 
             var sql = CreateDbTablesScript(_options.Value.Schema);
-            await using (var connection = new SqlConnection(_options.Value.ConnectionString))
+            using (var connection = new SqlConnection(_options.Value.ConnectionString))
             {
                 await connection.ExecuteAsync(sql);
             }