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));