From d6670d7c2b1c0efcd43cfc1342a3b237ba3b928b Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期二, 10 九月 2024 16:47:39 +0800
Subject: [PATCH] #fs
---
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 71d10d5..c52b3fc 100644
--- a/src/main/java/com/zy/core/ServerBootstrap.java
+++ b/src/main/java/com/zy/core/ServerBootstrap.java
@@ -49,10 +49,10 @@
}
private void initMq(){
-// // 鍒濆鍖朢GVmq
-// for (Slave rgv : slaveProperties.getRgv()) {
-// MessageQueue.init(SlaveType.Rgv, rgv);
-// }
+ // 鍒濆鍖朢GVmq
+ for (Slave rgv : slaveProperties.getRgv()) {
+ MessageQueue.init(SlaveType.Rgv, rgv);
+ }
// 鍒濆鍖栬緭閫佺嚎mq
for (Slave devp : slaveProperties.getDevp()) {
MessageQueue.init(SlaveType.Devp, devp);
@@ -80,20 +80,20 @@
}
private void initThread(){
-// // 鍒濆鍖栫┛姊溅绾跨▼
-// log.info("鍒濆鍖朢GV绾跨▼...................................................");
-// for (RgvSlave rgv : slaveProperties.getRgv()) {
-// RgvThread rgvThread = new RgvThread(rgv);
-// new Thread((Runnable) rgvThread).start();
-// SlaveConnection.put(SlaveType.Rgv, rgv.getId(), rgvThread);
-// }
-// // 鍒濆鍖栬緭閫佺嚎绾跨▼
-// 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("鍒濆鍖朢GV绾跨▼...................................................");
+ for (RgvSlave rgv : slaveProperties.getRgv()) {
+ RgvThread rgvThread = new RgvThread(rgv);
+ new Thread((Runnable) rgvThread).start();
+ SlaveConnection.put(SlaveType.Rgv, rgv.getId(), rgvThread);
+ }
+ // 鍒濆鍖栬緭閫佺嚎绾跨▼
+ 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("鍒濆鍖栨潯鐮佹壂鎻忎华绾跨▼...................................................");
--
Gitblit v1.9.1