diff --git a/src/main/java/com/eactive/eai/adapter/http/dynamic/HttpAdapterServiceSupport.java b/src/main/java/com/eactive/eai/adapter/http/dynamic/HttpAdapterServiceSupport.java index 61f5476..e8cebdb 100644 --- a/src/main/java/com/eactive/eai/adapter/http/dynamic/HttpAdapterServiceSupport.java +++ b/src/main/java/com/eactive/eai/adapter/http/dynamic/HttpAdapterServiceSupport.java @@ -18,6 +18,7 @@ import com.eactive.eai.adapter.http.dynamic.filter.HttpAdapterFilterFactory; import com.eactive.eai.adapter.http.dynamic.filter.HttpAdapterFilterType; import com.eactive.eai.adapter.http.dynamic.filter.JwtAuthException; import com.eactive.eai.common.TransactionContextKeys; +import com.eactive.eai.common.server.EAIServerManager; import com.eactive.eai.common.util.Logger; import com.eactive.eai.common.util.TxSiftContext; import com.eactive.eai.common.util.UUIDGenerator; @@ -31,13 +32,20 @@ public abstract class HttpAdapterServiceSupport implements HttpAdapterService, H public static final String PROPERTIES_NAME_CLIENT_ID = "clientId"; static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER); private ObjectMapper mapper = new ObjectMapper(); + EAIServerManager eaiServerManager; + String instid = null; public Object service(String adptGrpName, String adptName, Object message, Properties prop, HttpServletRequest request, HttpServletResponse response) throws Exception { String uuid = prop.getProperty(TransactionContextKeys.TRANSACTION_UUID); boolean bMDCput = false; + if(uuid == null) { - uuid = UUIDGenerator.getUUID().toString().replaceAll("-", ""); + if(instid == null) { + eaiServerManager = EAIServerManager.getInstance(); + instid = eaiServerManager.getGroupInstId(); + } + uuid = instid + UUIDGenerator.getUUID().toString().replaceAll("-", ""); prop.setProperty(TransactionContextKeys.TRANSACTION_UUID, uuid); }