From 09aa49c8d12e74f0cb99b510761f2873afff873b Mon Sep 17 00:00:00 2001
From: zy <zy@123>
Date: 星期一, 21 七月 2025 10:27:27 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/ServerBootstrap.java | 12 +++++-------
1 files changed, 5 insertions(+), 7 deletions(-)
diff --git a/src/main/java/com/zy/core/ServerBootstrap.java b/src/main/java/com/zy/core/ServerBootstrap.java
index 1dac4f8..1b617d9 100644
--- a/src/main/java/com/zy/core/ServerBootstrap.java
+++ b/src/main/java/com/zy/core/ServerBootstrap.java
@@ -30,8 +30,8 @@
@Value("${deviceMsgConfig.gatewayPort}")
private int gatewayPort;
- @Value("${deviceMsgConfig.enableFakeAndDeviceThread}")
- private boolean enableFakeAndDeviceThread;
+ @Value("${deviceMsgConfig.enableFakeDeviceThread}")
+ private boolean enableFakeDeviceThread;
@Value("${deviceMsgConfig.enableFake}")
private boolean enableFake;
@Autowired
@@ -78,15 +78,13 @@
}
private void initFakeThread(){
- if (!enableFake) {
- return;
- }
-
- ThreadHandler thread = new FakeNyShuttleThread(redisUtil, gatewayPort, enableFakeAndDeviceThread);
+ ThreadHandler thread = new FakeNyShuttleThread(redisUtil, gatewayPort, enableFake, enableFakeDeviceThread);
new Thread(thread).start();
+ SlaveConnection.put(SlaveType.FakeThread, 1, thread);
ThreadHandler thread2 = new FakeZyForkLiftThread(redisUtil);
new Thread(thread2).start();
+ SlaveConnection.put(SlaveType.FakeThread, 2, thread2);
}
--
Gitblit v1.9.1