| | |
| | | for (Slave car : slaveProperties.getCar()) { |
| | | MessageQueue.init(SlaveType.Car, car); |
| | | } |
| | | // 初始化socket mq |
| | | for (Slave socket : slaveProperties.getSocket()) { |
| | | MessageQueue.init(SlaveType.Socket, socket); |
| | | } |
| | | // // 初始化socket mq |
| | | // for (Slave socket : slaveProperties.getSocket()) { |
| | | // MessageQueue.init(SlaveType.Socket, socket); |
| | | // } |
| | | } |
| | | |
| | | private void initThread(){ |
| | |
| | | SlaveConnection.put(SlaveType.Barcode, barcode.getId(), barcodeThread); |
| | | } |
| | | |
| | | // 初始化条码扫描仪线程 |
| | | log.info("初始化Socket线程..................................................."); |
| | | for (SocketSlave socket : slaveProperties.getSocket()) { |
| | | SocketThread socketThread = new SocketThread(socket); |
| | | new Thread(socketThread).start(); |
| | | SlaveConnection.put(SlaveType.Socket, socket.getId(), socketThread); |
| | | } |
| | | // // 初始化条码扫描仪线程 |
| | | // log.info("初始化Socket线程..................................................."); |
| | | // for (SocketSlave socket : slaveProperties.getSocket()) { |
| | | // SocketThread socketThread = new SocketThread(socket); |
| | | // new Thread(socketThread).start(); |
| | | // SlaveConnection.put(SlaveType.Socket, socket.getId(), socketThread); |
| | | // } |
| | | // // 初始化LED线程 |
| | | // log.info("初始化LED线程..................................................."); |
| | | // for (LedSlave led : slaveProperties.getLed()) { |