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)