diff --git a/sdk/core/azure-core-amqp/CHANGELOG.md b/sdk/core/azure-core-amqp/CHANGELOG.md index 6453a9dc3c3d..ca8d0622d431 100644 --- a/sdk/core/azure-core-amqp/CHANGELOG.md +++ b/sdk/core/azure-core-amqp/CHANGELOG.md @@ -8,6 +8,8 @@ ### Bugs Fixed +- Fixed memory leak in azure-core-amqp `ReactorConnection` caused by redundant `cache()` operator. ([#44228](https://github.com/Azure/azure-sdk-for-java/issues/44228), [#47508](https://github.com/Azure/azure-sdk-for-java/issues/47508)) + ### Other Changes ## 2.11.2 (2025-10-06) diff --git a/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/ReactorConnection.java b/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/ReactorConnection.java index 4621a1f54356..58ca458207d4 100644 --- a/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/ReactorConnection.java +++ b/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/ReactorConnection.java @@ -238,7 +238,7 @@ public Flux getEndpointStates() { */ @Override public Flux getShutdownSignals() { - return shutdownSignalSink.asMono().cache().flux(); + return shutdownSignalSink.asMono().flux(); } @Override