Removing duplicate ReactorSession::closeAsync call in session-endpoin…

…t error-handler. (#40667)
Azure · Jun 17, 2024 · d53f07c · d53f07c
1 parent 4180276
commit d53f07c
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/...core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/ReactorSession.java b/...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;
         }