Dispatch the update secrets (#362)

- Dispatch to all the pool connections Signed-off-by: Gabriele Santomaggio <G.santomaggio@gmail.com>
rabbitmq · Feb 23, 2024 · bf6f5bf · bf6f5bf
1 parent 915ae8a
commit bf6f5bf
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/RabbitMQ.Stream.Client/StreamSystem.cs b/RabbitMQ.Stream.Client/StreamSystem.cs
@@ -161,7 +161,8 @@ public async Task UpdateSecret(string newSecret)
             await _client.UpdateSecret(newSecret).ConfigureAwait(false);
             _clientParameters.Password = newSecret;
             _client.Parameters.Password = newSecret;
-
+            await PoolConsumers.UpdateSecrets(newSecret).ConfigureAwait(false);
+            await PoolProducers.UpdateSecrets(newSecret).ConfigureAwait(false);
         }
 
         public async Task<ISuperStreamProducer> CreateRawSuperStreamProducer(