Add missing ConfigureAwait(false)

Author: Havret

ActiveMQ.Artemis.Client.sln.DotSettings

@@ -1,4 +1,6 @@
 <wpf:ResourceDictionary xml:space="preserve" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:s="clr-namespace:System;assembly=mscorlib" xmlns:ss="urn:shemas-jetbrains-com:settings-storage-xaml" xmlns:wpf="http://schemas.microsoft.com/winfx/2006/xaml/presentation">
+	<s:String x:Key="/Default/CodeInspection/Highlighting/InspectionSeverities/=UseConfigureAwaitFalse/@EntryIndexedValue">ERROR</s:String>
+	<s:String x:Key="/Default/CodeInspection/Highlighting/InspectionSeverities/=UseConfigureAwaitFalseForAsyncDisposable/@EntryIndexedValue">WARNING</s:String>
 	<s:String x:Key="/Default/CodeStyle/Naming/CSharpNaming/PredefinedNamingRules/=PrivateStaticReadonly/@EntryIndexedValue">&lt;Policy Inspect="True" Prefix="_" Suffix="" Style="aaBb" /&gt;</s:String>
 	<s:Boolean x:Key="/Default/UserDictionary/Words/=Amqp/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/UserDictionary/Words/=Amqps/@EntryIndexedValue">True</s:Boolean>

src/ArtemisNetClient.Extensions.DependencyInjection/ActiveMqArtemisClientDependencyInjectionExtensions.cs

@@ -371,7 +371,7 @@ private static void AddConsumer(this IActiveMqBuilder builder,
                 configureContextualReceiveObservableAction(contextualReceiveObservable);
                 return new ActiveMqConsumer(provider, contextualReceiveObservable, async token =>
                 {
-                    var connection = await provider.GetConnection(builder.Name, token);
+                    var connection = await provider.GetConnection(builder.Name, token).ConfigureAwait(false);
                     return await connection.CreateConsumerAsync(consumerConfiguration, token).ConfigureAwait(false);
                 }, handler);
             });
@@ -496,7 +496,7 @@ private static IActiveMqBuilder AddProducer<TProducer>(this IActiveMqBuilder bui
                 };
                 return new TypedActiveMqProducer<TProducer>(logger, async token =>
                 {
-                    var connection = await provider.GetConnection(builder.Name, token);
+                    var connection = await provider.GetConnection(builder.Name, token).ConfigureAwait(false);
                     return await connection.CreateProducerAsync(producerConfiguration, token).ConfigureAwait(false);
                 }, contextualSendObservable);
             });

src/ArtemisNetClient.Extensions.DependencyInjection/ActiveMqTopologyManager.cs

@@ -27,11 +27,12 @@ public async Task CreateTopologyAsync(CancellationToken cancellationToken)
             }
 
             var connection = await _lazyConnection.GetValueAsync(cancellationToken).ConfigureAwait(false);
-            await using var topologyManager = await connection.CreateTopologyManagerAsync(cancellationToken).ConfigureAwait(false);
+            var topologyManager = await connection.CreateTopologyManagerAsync(cancellationToken).ConfigureAwait(false);
+            await using var _ = topologyManager.ConfigureAwait(false);
 
             foreach (var addressConfiguration in _addressConfigurations)
             {
-                await topologyManager.DeclareAddressAsync(addressConfiguration.Key, addressConfiguration.Value, cancellationToken);
+                await topologyManager.DeclareAddressAsync(addressConfiguration.Key, addressConfiguration.Value, cancellationToken).ConfigureAwait(false);
             }
 
             var queues = await topologyManager.GetQueueNamesAsync(cancellationToken).ConfigureAwait(false);

src/ArtemisNetClient.Extensions.DependencyInjection/ArtemisNetClient.Extensions.DependencyInjection.csproj.DotSettings

@@ -1,4 +1,5 @@
 <wpf:ResourceDictionary xml:space="preserve" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:s="clr-namespace:System;assembly=mscorlib" xmlns:ss="urn:shemas-jetbrains-com:settings-storage-xaml" xmlns:wpf="http://schemas.microsoft.com/winfx/2006/xaml/presentation">
 	<s:String x:Key="/Default/CodeInspection/CSharpLanguageProject/LanguageLevel/@EntryValue">CSharp80</s:String>
+	<s:String x:Key="/Default/CodeInspection/Daemon/ConfigureAwaitAnalysisMode/@EntryValue">Library</s:String>
 	<s:Boolean x:Key="/Default/CodeInspection/NamespaceProvider/NamespaceFoldersToSkip/=observables/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/CodeInspection/NamespaceProvider/NamespaceFoldersToSkip/=options/@EntryIndexedValue">True</s:Boolean></wpf:ResourceDictionary>

src/ArtemisNetClient.Extensions.DependencyInjection/ConnectionProvider.cs

@@ -19,7 +19,7 @@ public ConnectionProvider(IServiceProvider serviceProvider)
         public async ValueTask<IConnection> GetConnection(string name, CancellationToken cancellationToken)
         {
             var namedConnection = _serviceProvider.GetServices<NamedConnection>().First(x => x.Name == name);
-            return await namedConnection.Connection.GetValueAsync(cancellationToken);
+            return await namedConnection.Connection.GetValueAsync(cancellationToken).ConfigureAwait(false);
         }
 
         public AsyncValueLazy<IConnection> GetConnection(string name)

src/ArtemisNetClient.Extensions.DependencyInjection/TypedActiveMqAnonymousProducer.cs

@@ -27,7 +27,7 @@ public async ValueTask StartAsync(CancellationToken cancellationToken)
                 throw new InvalidOperationException($"Producer with type {typeof(T).FullName} has already been initialized.");
             }
 
-            _producer = await _producerFactory(cancellationToken);
+            _producer = await _producerFactory(cancellationToken).ConfigureAwait(false);
         }
 
         public async ValueTask StopAsync()

src/ArtemisNetClient.Extensions.DependencyInjection/TypedActiveMqProducer.cs

@@ -27,7 +27,7 @@ async ValueTask IActiveMqProducer.StartAsync(CancellationToken cancellationToken
                 throw new InvalidOperationException($"Producer with type {typeof(T).FullName} has already been initialized.");
             }
 
-            _producer = await _producerFactory(cancellationToken);
+            _producer = await _producerFactory(cancellationToken).ConfigureAwait(false);
         }
 
         public async ValueTask StopAsync()

src/ArtemisNetClient.Extensions.LeaderElection/ArtemisNetClient.Extensions.LeaderElection.csproj.DotSettings

@@ -1,2 +1,3 @@
 <wpf:ResourceDictionary xml:space="preserve" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:s="clr-namespace:System;assembly=mscorlib" xmlns:ss="urn:shemas-jetbrains-com:settings-storage-xaml" xmlns:wpf="http://schemas.microsoft.com/winfx/2006/xaml/presentation">
-	<s:String x:Key="/Default/CodeInspection/CSharpLanguageProject/LanguageLevel/@EntryValue">CSharp80</s:String></wpf:ResourceDictionary>
+	<s:String x:Key="/Default/CodeInspection/CSharpLanguageProject/LanguageLevel/@EntryValue">CSharp80</s:String>
+	<s:String x:Key="/Default/CodeInspection/Daemon/ConfigureAwaitAnalysisMode/@EntryValue">Library</s:String></wpf:ResourceDictionary>

src/ArtemisNetClient.Testing/ArtemisNetClient.Testing.csproj.DotSettings

@@ -0,0 +1,2 @@
+<wpf:ResourceDictionary xml:space="preserve" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:s="clr-namespace:System;assembly=mscorlib" xmlns:ss="urn:shemas-jetbrains-com:settings-storage-xaml" xmlns:wpf="http://schemas.microsoft.com/winfx/2006/xaml/presentation">
+	<s:String x:Key="/Default/CodeInspection/Daemon/ConfigureAwaitAnalysisMode/@EntryValue">Library</s:String></wpf:ResourceDictionary>

src/ArtemisNetClient.Testing/Listener/Extensions.cs

@@ -1,5 +1,4 @@
 using System.Reflection;
-using ActiveMQ.Artemis.Client.Testing.Utils;
 using Amqp.Framing;
 using Amqp.Listener;