Merge pull request #2206 from senthuran16/fix-eptimeout-conn-close_ma…

…ster Fix connection close during endpoint timeout when reusing a connection
wso2 · Jul 25, 2024 · 8648562 · 8648562
2 parents ff65b7b + 7a680ac
commit 8648562
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...nsports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/DeliveryAgent.java b/...nsports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/DeliveryAgent.java
@@ -259,9 +259,6 @@ public void connected(HttpRoute route, NHttpClientConnection conn) {
                 MessageContext messageContext = queue.poll();
 
                 if (messageContext != null) {
-                    messageContext.setProperty(PassThroughConstants.PASS_THROUGH_TARGET_CONNECTION, conn);
-                    messageContext.setProperty(PassThroughConstants.PASS_THROUGH_TARGET_CONFIGURATION,
-                            targetConfiguration);
                     tryNextMessage(messageContext, route, conn);
                     conn = null;
                 }
@@ -279,6 +276,8 @@ public void connected(HttpRoute route, NHttpClientConnection conn) {
     private void tryNextMessage(MessageContext messageContext, HttpRoute route, NHttpClientConnection conn) {
         if (conn != null) {
             try {
+                messageContext.setProperty(PassThroughConstants.PASS_THROUGH_TARGET_CONNECTION, conn);
+                messageContext.setProperty(PassThroughConstants.PASS_THROUGH_TARGET_CONFIGURATION, targetConfiguration);
                 HttpContext ctx = conn.getContext();
                 /*
                 * If the flow is SSE we need to set references to target connection and targetConnections