From d53f07ca99d194dc53e74a6b54afd5c36164424c Mon Sep 17 00:00:00 2001 From: Anu Thomas Chandy Date: Mon, 17 Jun 2024 15:22:04 -0700 Subject: [PATCH] Removing duplicate ReactorSession::closeAsync call in session-endpoint error-handler. (#40667) --- .../com/azure/core/amqp/implementation/ReactorSession.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/ReactorSession.java b/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/ReactorSession.java index 86317730c41d..a27d58bc825a 100644 --- a/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/ReactorSession.java +++ b/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/ReactorSession.java @@ -658,10 +658,7 @@ private void handleError(Throwable error) { final AmqpException exception = ((AmqpException) error); final String errorCondition = exception.getErrorCondition() != null ? exception.getErrorCondition().getErrorCondition() : "UNKNOWN"; - condition = new ErrorCondition(Symbol.getSymbol(errorCondition), exception.getMessage()); - - closeAsync(exception.getMessage(), condition, true).subscribe(); } else { condition = null; }