diff --git a/jcpp-app/src/main/java/sanbing/jcpp/app/service/queue/consumer/ProtocolUplinkConsumerService.java b/jcpp-app/src/main/java/sanbing/jcpp/app/service/queue/consumer/ProtocolUplinkConsumerService.java index 6300ea2..de8b33b 100644 --- a/jcpp-app/src/main/java/sanbing/jcpp/app/service/queue/consumer/ProtocolUplinkConsumerService.java +++ b/jcpp-app/src/main/java/sanbing/jcpp/app/service/queue/consumer/ProtocolUplinkConsumerService.java @@ -143,14 +143,6 @@ 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();