| | |
| | | for (Slave devp : slaveProperties.getDevp()) { |
| | | MessageQueue.init(SlaveType.Devp, devp); |
| | | } |
| | | for (Slave devp2 : slaveProperties.getDevp2()) { |
| | | MessageQueue.init(SlaveType.Devp2, devp2); |
| | | } |
| | | // 初始化条码扫描仪mq |
| | | for (Slave barcode : slaveProperties.getBarcode()) { |
| | | MessageQueue.init(SlaveType.Barcode, barcode); |
| | |
| | | new Thread((Runnable) devpThread).start(); |
| | | SlaveConnection.put(SlaveType.Devp, devp.getId(), devpThread); |
| | | } |
| | | for (Devp2Slave devp2 : slaveProperties.getDevp2()) { |
| | | SiemensDevpThread2 siemensDevpThread2 = new SiemensDevpThread2(devp2); |
| | | new Thread(siemensDevpThread2).start(); |
| | | SlaveConnection.put(SlaveType.Devp2, devp2.getId(), siemensDevpThread2); |
| | | } |
| | | // 初始化提升机 |
| | | News.info("初始化提升机........................................................"); |
| | | for (LiftSlave liftSlave : slaveProperties.getLift()) { |