From 8353d857cae5c623e29406dcbe8c9a870d527b6e Mon Sep 17 00:00:00 2001
From: lsh <lsh>
Date: 星期四, 16 五月 2024 09:33:24 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/ServerBootstrap.java | 36 ++++++++++++++++++------------------
1 files changed, 18 insertions(+), 18 deletions(-)
diff --git a/src/main/java/com/zy/core/ServerBootstrap.java b/src/main/java/com/zy/core/ServerBootstrap.java
index c8fe405..69867d6 100644
--- a/src/main/java/com/zy/core/ServerBootstrap.java
+++ b/src/main/java/com/zy/core/ServerBootstrap.java
@@ -62,10 +62,10 @@
MessageQueue.init(SlaveType.Rgv, rgv);
}
- // 鍒濆鍖栨満姊拌噦mq
- for (Slave ext : slaveProperties.getExt()) {
- MessageQueue.init(SlaveType.Ext, ext);
- }
+// // 鍒濆鍖栨満姊拌噦mq
+// for (Slave ext : slaveProperties.getExt()) {
+// MessageQueue.init(SlaveType.Ext, ext);
+// }
// // 鍒濆鍖朙ed鐏痬q
// for (Slave led : slaveProperties.getLed()) {
// MessageQueue.init(SlaveType.Led, led);
@@ -88,13 +88,13 @@
// new Thread((Runnable) crnThread).start();
// SlaveConnection.put(SlaveType.Crn, crn.getId(), crnThread);
// }
-// // 鍒濆鍖栬緭閫佺嚎绾跨▼
-// log.info("鍒濆鍖栬緭閫佺嚎绾跨▼...................................................");
-// for (DevpSlave devp : slaveProperties.getDevp()) {
-// DevpThread devpThread = new SiemensDevpThread(devp);
-// new Thread((Runnable) devpThread).start();
-// SlaveConnection.put(SlaveType.Devp, devp.getId(), devpThread);
-// }
+ // 鍒濆鍖栬緭閫佺嚎绾跨▼
+ log.info("鍒濆鍖栬緭閫佺嚎绾跨▼...................................................");
+ for (DevpSlave devp : slaveProperties.getDevp()) {
+ DevpThread devpThread = new SiemensDevpThread(devp);
+ new Thread((Runnable) devpThread).start();
+ SlaveConnection.put(SlaveType.Devp, devp.getId(), devpThread);
+ }
// // 鍒濆鍖栨潯鐮佹壂鎻忎华绾跨▼
// log.info("鍒濆鍖栨潯鐮佹壂鎻忎华绾跨▼...................................................");
// for (Slave barcode : slaveProperties.getBarcode()) {
@@ -109,13 +109,13 @@
new Thread((Runnable) rgvThread).start();
SlaveConnection.put(SlaveType.Rgv, rgv.getId(), rgvThread);
}
- // 鍒濆鍖栨満姊拌噦绾跨▼
- log.info("鍒濆鍖朎xt绾跨▼...................................................");
- for (ExtSlave ext : slaveProperties.getExt()) {
- MelsecExtThread extThread = new MelsecExtThread(ext);
- new Thread(extThread).start();
- SlaveConnection.put(SlaveType.Ext, ext.getId(), extThread);
- }
+// // 鍒濆鍖栨満姊拌噦绾跨▼
+// log.info("鍒濆鍖朎xt绾跨▼...................................................");
+// for (ExtSlave ext : slaveProperties.getExt()) {
+// MelsecExtThread extThread = new MelsecExtThread(ext);
+// new Thread(extThread).start();
+// SlaveConnection.put(SlaveType.Ext, ext.getId(), extThread);
+// }
// // 鍒濆鍖朙ED绾跨▼
// log.info("鍒濆鍖朙ED绾跨▼...................................................");
// for (LedSlave led : slaveProperties.getLed()) {
--
Gitblit v1.9.1