Junjie
2023-08-03 60caf3656ab1af6f5ec5c35b61958df7016e9f3a
注释磅秤
1个文件已修改
22 ■■■■ 已修改文件
src/main/java/com/zy/core/ServerBootstrap.java 22 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/core/ServerBootstrap.java
@@ -63,10 +63,10 @@
//        for (Slave led : slaveProperties.getLed()) {
//            MessageQueue.init(SlaveType.Led, led);
//        }
        // 初始化磅称mq
        for (Slave scale : slaveProperties.getScale()) {
            MessageQueue.init(SlaveType.Scale, scale);
        }
//        // 初始化磅称mq
//        for (Slave scale : slaveProperties.getScale()) {
//            MessageQueue.init(SlaveType.Scale, scale);
//        }
//        // 初始化台车mq
//        for (Slave car : slaveProperties.getCar()) {
//            MessageQueue.init(SlaveType.Car, car);
@@ -102,13 +102,13 @@
//            new Thread(ledThread).start();
//            SlaveConnection.put(SlaveType.Led, led.getId(), ledThread);
//        }
//         初始化磅秤线程
        log.info("初始化磅秤线程...................................................");
        for (Slave scale : slaveProperties.getScale()) {
            ScaleThread scaleThread = new ScaleThread(scale);
            new Thread(scaleThread).start();
            SlaveConnection.put(SlaveType.Scale, scale.getId(), scaleThread);
        }
//        // 初始化磅秤线程
//        log.info("初始化磅秤线程...................................................");
//        for (Slave scale : slaveProperties.getScale()) {
//            ScaleThread scaleThread = new ScaleThread(scale);
//            new Thread(scaleThread).start();
//            SlaveConnection.put(SlaveType.Scale, scale.getId(), scaleThread);
//        }
    }