Add error code and error message

Add error code and error message to synapse message context in the fault sequence.
wso2 · Jun 18, 2024 · 6e38cc1 · 6e38cc1
1 parent c96d4f8
commit 6e38cc1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...t.transport/src/main/java/org/wso2/carbon/websocket/transport/WebSocketClientHandler.java b/...t.transport/src/main/java/org/wso2/carbon/websocket/transport/WebSocketClientHandler.java
@@ -223,6 +223,8 @@ private void invokeFaultSequenceUponError(int statusCode, String reasonText) thr
         MessageContext synCtx = getSynapseMessageContext(tenantDomain);
         synCtx.setProperty(InboundWebsocketConstants.WEB_SOCKET_CLOSE_CODE, statusCode);
         synCtx.setProperty(InboundWebsocketConstants.WEB_SOCKET_REASON_TEXT, reasonText);
+        synCtx.setProperty(WebsocketConstants.ERROR_CODE, statusCode);
+        synCtx.setProperty(WebsocketConstants.ERROR_MESSAGE, reasonText);
         synCtx.setProperty(InboundWebsocketConstants.FAULT_SEQUENCE_INVOKED_ON_WEBSOCKET_CLIENT_HANDLER_ERROR, true);
         getFaultSequence(synCtx, dispatchErrorSequence).mediate(synCtx);
     }

diff --git a/...ocket.transport/src/main/java/org/wso2/carbon/websocket/transport/WebsocketConstants.java b/...ocket.transport/src/main/java/org/wso2/carbon/websocket/transport/WebsocketConstants.java
@@ -80,4 +80,6 @@ public class WebsocketConstants {
     public static final String WS_CLOSE_DEFAULT_REASON_TEXT = "Websocket server terminated";
 
     public static final int WEBSOCKET_UPSTREAM_ERROR_SC = 1014;
+    public static final String ERROR_CODE = "ERROR_CODE";
+    public static final String ERROR_MESSAGE = "ERROR_MESSAGE";
 }