| | |
| | | for (Slave ste : slaveProperties.getSte()) { |
| | | MessageQueue.init(SlaveType.Ste, ste); |
| | | } |
| | | // 初始化提升机mq |
| | | for (Slave lift : slaveProperties.getLift()) { |
| | | MessageQueue.init(SlaveType.Lift, lift); |
| | | } |
| | | // 初始化四向穿梭车mq |
| | | for (Slave shuttle : slaveProperties.getShuttle()) { |
| | | MessageQueue.init(SlaveType.Shuttle, shuttle); |
| | |
| | | // 初始化提升机 |
| | | News.info("初始化提升机........................................................"); |
| | | for (LiftSlave liftSlave : slaveProperties.getLift()) { |
| | | LiftThread liftThread = new LiftThread(liftSlave); |
| | | LiftThread liftThread = new LiftThread(liftSlave, redisUtil); |
| | | new Thread(liftThread).start(); |
| | | SlaveConnection.put(SlaveType.Lift, liftSlave.getId(), liftThread); |
| | | } |