src/main/java/com/zy/core/ServerBootstrap.java
@@ -58,6 +58,10 @@ for (Slave shuttle : slaveProperties.getShuttle()) { MessageQueue.init(SlaveType.Shuttle, shuttle); } // 初始化输送线mq for (Slave devp : slaveProperties.getDevp()) { MessageQueue.init(SlaveType.Devp, devp); } } private void initThread() {