From ee5046d151a858339aa137790bc830efe7f55980 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期三, 18 六月 2025 15:13:14 +0800
Subject: [PATCH] 1
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvDataSubscriber.java | 17 +++++++++--------
1 files changed, 9 insertions(+), 8 deletions(-)
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvDataSubscriber.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvDataSubscriber.java
index 77a10ad..36e9c5e 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvDataSubscriber.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvDataSubscriber.java
@@ -31,7 +31,7 @@
@EventListener(ApplicationReadyEvent.class)
- private void start(){
+ private void start() {
// redis.deleteList(RedisConstant.AGV_DATA_FLAG);
thread = new Thread(() -> {
while (!Thread.currentThread().isInterrupted()) {
@@ -39,22 +39,23 @@
// 闂撮殧
Thread.sleep(10);
- if (configService.getVal("stopDownData", Boolean.class)) { return; }
+ if (!configService.getVal("stopDownData", Boolean.class)) {
+ AgvProtocol protocol = redis.pop(RedisConstant.AGV_DATA_FLAG);
+ if (null != protocol) {
- AgvProtocol protocol = redis.pop(RedisConstant.AGV_DATA_FLAG);
- if (null != protocol){
-
- agvDataService.dataProcess(protocol);
+ agvDataService.dataProcess(protocol);
+ }
}
- } catch (Exception ignore) {}
+ } catch (Exception ignore) {
+ }
}
});
thread.start();
}
@PreDestroy
- public void shutDown(){
+ public void shutDown() {
if (thread != null) thread.interrupt();
}
--
Gitblit v1.9.1