From a1bed4579bbdee979bfa1587f23cce9c296f0516 Mon Sep 17 00:00:00 2001 From: luoyifan Date: Thu, 3 Jul 2025 13:30:06 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=AF=E5=8A=A8=E9=A1=BA=E5=BA=8F=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/core/manager/EnvManager.ts | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/core/manager/EnvManager.ts b/src/core/manager/EnvManager.ts index 66261e9..bbb2703 100644 --- a/src/core/manager/EnvManager.ts +++ b/src/core/manager/EnvManager.ts @@ -63,7 +63,7 @@ export default class EnvManager { worldModel.state.runState.currentEnv = env try { await LCC.serverStart() - await LCC.loadExecutor() + await worldModel.lccMqttManager.start(env.envConfig.frontendMqtt) await LCC.loadInv() this.client = mqtt.connect(env.envConfig.mqtt.websocket, { @@ -77,7 +77,8 @@ export default class EnvManager { keepalive: 60 }) - await worldModel.lccMqttManager.start(env.envConfig.frontendMqtt) + await LCC.loadExecutor() + this.client.on('connect', this.onMqttConnect) this.client.on('message', this.onMqttMessage) this.client.on('error', this.onMqttError)