过期请求不处理

jcpp-app/src/main/java/sanbing/jcpp/app/service/queue/consumer/ProtocolUplinkConsumerService.java

@@ -141,6 +141,14 @@ public class ProtocolUplinkConsumerService extends AbstractConsumerService imple
 
                     Callback callback = new PackCallback<>(id, ctx);
 
+                    // 过期请求不处理
+                    if (TracerContextUtil.getCurrentTracer().getTracerTs() < (System.currentTimeMillis() - packProcessingTimeout)) {
+
+                        callback.onSuccess();
+
+                        return;
+                    }
+
                     try {
                         UplinkQueueMessage uplinkQueueMsg = msg.getValue();