|
|
@@ -39,7 +39,6 @@ import { Device } from '../device/entities/device.entity'
|
|
|
import Decimal from 'decimal.js'
|
|
|
import { CountryConfigService } from '../country-config/country-config.service'
|
|
|
import { TaskResult } from './types'
|
|
|
-import { connectAsync as mqttConnect, MqttClient } from 'mqtt'
|
|
|
|
|
|
export const batchSize = 9
|
|
|
|
|
|
@@ -47,7 +46,6 @@ export const batchSize = 9
|
|
|
export class TaskService implements OnModuleInit {
|
|
|
private lock = new AsyncLock()
|
|
|
private TAG = 'TaskService'
|
|
|
- private mqttClient: MqttClient
|
|
|
constructor(
|
|
|
@InjectRepository(Task)
|
|
|
private taskRepository: Repository<Task>,
|
