From 5d9676b50478b6f9bd7f4c51e06971591b8dac2f Mon Sep 17 00:00:00 2001 From: curry772 Date: Fri, 3 Jul 2026 08:55:37 +0900 Subject: [PATCH] =?UTF-8?q?=EC=88=98=EC=8B=A0=20=EC=8B=9C=EA=B0=81?= =?UTF-8?q?=EC=9D=B4=20=ED=94=84=EB=9F=AC=ED=8D=BC=ED=8B=B0=EC=97=90=20?= =?UTF-8?q?=EC=9E=88=EC=9D=84=20=EA=B2=BD=EC=9A=B0=20=EA=B7=B8=20=EA=B0=92?= =?UTF-8?q?=EC=9D=84=20=EC=82=AC=EC=9A=A9=ED=95=98=EB=8F=84=EB=A1=9D=20?= =?UTF-8?q?=EC=88=98=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../eai/inbound/processor/RequestProcessorSupport.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/eactive/eai/inbound/processor/RequestProcessorSupport.java b/src/main/java/com/eactive/eai/inbound/processor/RequestProcessorSupport.java index 0f93eb1..358286a 100644 --- a/src/main/java/com/eactive/eai/inbound/processor/RequestProcessorSupport.java +++ b/src/main/java/com/eactive/eai/inbound/processor/RequestProcessorSupport.java @@ -11,6 +11,7 @@ import org.springframework.http.HttpStatus; import com.eactive.eai.adapter.AdapterGroupVO; import com.eactive.eai.adapter.AdapterManager; import com.eactive.eai.adapter.http.HttpStatusException; +import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceKey; import com.eactive.eai.adapter.http.dynamic.filter.JwtAuthException; import com.eactive.eai.common.exception.ExceptionHandler; import com.eactive.eai.common.message.EAIMessage; @@ -111,7 +112,13 @@ public abstract class RequestProcessorSupport implements Processor **/ public Object execute(Object message, Properties prop) throws HttpStatusException { - long msgRcvTm = System.currentTimeMillis(); + String receivedTimestamp = prop.getProperty(HttpAdapterServiceKey.INBOUND_REQUESTED_TIME); + long msgRcvTm = 0L; + if(receivedTimestamp == null) + msgRcvTm = System.currentTimeMillis(); + else + msgRcvTm = Long.parseLong(receivedTimestamp); + increaseRcvCount(); local.set(new Long(msgRcvTm));