diff --git a/RabbitMQ.Stream.Client/StreamSystem.cs b/RabbitMQ.Stream.Client/StreamSystem.cs index b549f100..f2b0fd99 100644 --- 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 CreateRawSuperStreamProducer(