|  |  |  | 
|---|
|  |  |  | for (Slave devp : slaveProperties.getDevp()) { | 
|---|
|  |  |  | MessageQueue.init(SlaveType.Devp, devp); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //        // 初始化条码扫描仪mq | 
|---|
|  |  |  | //        for (Slave barcode : slaveProperties.getBarcode()) { | 
|---|
|  |  |  | //            MessageQueue.init(SlaveType.Barcode, barcode); | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | // 初始化条码扫描仪mq | 
|---|
|  |  |  | for (Slave barcode : slaveProperties.getBarcode()) { | 
|---|
|  |  |  | MessageQueue.init(SlaveType.Barcode, barcode); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //        // 初始化Led灯mq | 
|---|
|  |  |  | //        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); | 
|---|
|  |  |  | 
|---|
|  |  |  | //            new Thread(ledThread).start(); | 
|---|
|  |  |  | //            SlaveConnection.put(SlaveType.Led, led.getId(), ledThread); | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | // 初始化磅秤线程 | 
|---|
|  |  |  | //        // 初始化磅秤线程 | 
|---|
|  |  |  | //        log.info("初始化磅秤线程..................................................."); | 
|---|
|  |  |  | //        for (Slave scale : slaveProperties.getScale()) { | 
|---|
|  |  |  | //            ScaleThread barcodeThread = new ScaleThread(scale); | 
|---|
|  |  |  | //            new Thread(barcodeThread).start(); | 
|---|
|  |  |  | //            SlaveConnection.put(SlaveType.Scale, scale.getId(), barcodeThread); | 
|---|
|  |  |  | //            ScaleThread scaleThread = new ScaleThread(scale); | 
|---|
|  |  |  | //            new Thread(scaleThread).start(); | 
|---|
|  |  |  | //            SlaveConnection.put(SlaveType.Scale, scale.getId(), scaleThread); | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|