|
|
@ -63,7 +63,7 @@ export default class EnvManager { |
|
|
worldModel.state.runState.currentEnv = env |
|
|
worldModel.state.runState.currentEnv = env |
|
|
try { |
|
|
try { |
|
|
await LCC.serverStart() |
|
|
await LCC.serverStart() |
|
|
await LCC.loadExecutor() |
|
|
await worldModel.lccMqttManager.start(env.envConfig.frontendMqtt) |
|
|
await LCC.loadInv() |
|
|
await LCC.loadInv() |
|
|
|
|
|
|
|
|
this.client = mqtt.connect(env.envConfig.mqtt.websocket, { |
|
|
this.client = mqtt.connect(env.envConfig.mqtt.websocket, { |
|
|
@ -77,7 +77,8 @@ export default class EnvManager { |
|
|
keepalive: 60 |
|
|
keepalive: 60 |
|
|
}) |
|
|
}) |
|
|
|
|
|
|
|
|
await worldModel.lccMqttManager.start(env.envConfig.frontendMqtt) |
|
|
await LCC.loadExecutor() |
|
|
|
|
|
|
|
|
this.client.on('connect', this.onMqttConnect) |
|
|
this.client.on('connect', this.onMqttConnect) |
|
|
this.client.on('message', this.onMqttMessage) |
|
|
this.client.on('message', this.onMqttMessage) |
|
|
this.client.on('error', this.onMqttError) |
|
|
this.client.on('error', this.onMqttError) |
|
|
|