From dcf74c13cc226cf03611c76a079326955e114c1e Mon Sep 17 00:00:00 2001 From: "Przemek Krol (AccessUkLtd)" Date: Thu, 8 Jan 2026 19:26:43 +0100 Subject: [PATCH 1/2] Fix memory leak in ReactorConnection.getShutdownSignals() Fixes #44228, #47508 Related to #28235 --- .../com/azure/core/amqp/implementation/ReactorConnection.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 From 880e5734dbe4cad9c7f30e1138ed0ace935f1c3c Mon Sep 17 00:00:00 2001 From: "Przemek Krol (AccessUkLtd)" Date: Mon, 12 Jan 2026 10:58:53 +0100 Subject: [PATCH 2/2] update changelog --- sdk/core/azure-core-amqp/CHANGELOG.md | 2 ++ 1 file changed, 2 insertions(+) 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)