src/main/java/com/zy/core/ServerBootstrap.java
@@ -74,10 +74,10 @@ 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(){