Mark error Handler during error scenario

shilmyhasan · May 16, 2023 · 0c66741 · 0c66741
1 parent be07c71
commit 0c66741
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...ansports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/ClientWorker.java b/...ansports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/ClientWorker.java
@@ -145,6 +145,8 @@ public ClientWorker(TargetConfiguration targetConfiguration,
                 outMsgCtx.getProperty(PassThroughConstants.PASS_THROUGH_SOURCE_CONFIGURATION));
         responseMsgCtx.setProperty(AddressingConstants.DISABLE_ADDRESSING_FOR_IN_MESSAGES,
                 outMsgCtx.getProperty(AddressingConstants.DISABLE_ADDRESSING_FOR_IN_MESSAGES));
+        responseMsgCtx.setProperty(PassThroughConstants.INTERNAL_EXCEPTION_ORIGIN,
+                outMsgCtx.getProperty(PassThroughConstants.INTERNAL_EXCEPTION_ORIGIN));
 
         responseMsgCtx.setServerSide(true);
         responseMsgCtx.setDoingREST(outMsgCtx.isDoingREST());

diff --git a/...nsports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/TargetHandler.java b/...nsports/core/nhttp/src/main/java/org/apache/synapse/transport/passthru/TargetHandler.java
@@ -381,6 +381,8 @@ public void responseReceived(NHttpClientConnection conn) {
                 // waiting on writing the request out, will get notified. And we will proceed with the response
                 // regardless of the http status code. But mark target and source connections to be closed.
                 informWriterError(conn);
+                requestMsgContext.setProperty(PassThroughConstants.INTERNAL_EXCEPTION_ORIGIN,
+                        PassThroughConstants.INTERNAL_ORIGIN_ERROR_HANDLER);
                 StatusLine errorStatus = response.getStatusLine();
                 if (errorStatus != null) {
                     TargetContext.updateState(conn, ProtocolState.REQUEST_DONE);