Fix failing test

Give broker time to clean up the resources

Author: Havret

test/ActiveMQ.Artemis.Client.IntegrationTests/AddressModelSpec.cs

@@ -132,6 +132,9 @@ await topologyManager.CreateQueueAsync(new QueueConfiguration
             await queue2Consumer1.DisposeAsync();
             await queue2Consumer2.DisposeAsync();
 
+            // give broker time to clean up the resources
+            await Task.Delay(100);
+
             await using var newQueue1Consumer1 = await connection2.CreateConsumerAsync(address, queue1);
             await using var newQueue1Consumer2 = await connection2.CreateConsumerAsync(address, queue1);
             await using var newQueue2Consumer1 = await connection2.CreateConsumerAsync(address, queue2);

test/ActiveMQ.Artemis.Client.UnitTests/AutoRecovering/AutoRecoveringConsumerSpec.cs

@@ -38,18 +38,18 @@ public async Task Should_be_able_to_receive_messages_when_connection_restored()
         [Fact]
         public async Task Should_be_able_to_receive_message_when_connection_restored_after_receive_called()
         {
-            var endpoint = GetUniqueEndpoint();
-            var host1 = CreateOpenedContainerHost(endpoint);
+            var host1 = CreateOpenedContainerHost();
+            var host2 = CreateContainerHost();
 
-            var connection = await CreateConnection(endpoint);
+            var connection = await CreateConnection(new[] { host1.Endpoint, host2.Endpoint });
             var consumer = await connection.CreateConsumerAsync("a1", RoutingType.Anycast);
 
             var cts = new CancellationTokenSource(Timeout);
             var receiveTask = consumer.ReceiveAsync(cts.Token);
 
+            host2.Open();
             host1.Dispose();
 
-            var host2 = CreateOpenedContainerHost(endpoint);
             var messageSource = host2.CreateMessageSource("a1");
             messageSource.Enqueue(new Message("foo"));