| | |
| | | package com.ard.sample.wayline.service.impl; |
| | | |
| | | import com.ard.sample.common.error.CommonErrorEnum; |
| | | import com.ard.sample.common.model.ResponseResult; |
| | | import com.ard.sample.component.mqtt.model.*; |
| | | import com.ard.sample.component.mqtt.service.IMessageSenderService; |
| | |
| | | log.info("Task progress: {}", output.getProgress().toString()); |
| | | |
| | | if (eventsReceiver.getResult() != ResponseResult.CODE_SUCCESS) { |
| | | log.error("Task progress ===> Error code: " + eventsReceiver.getResult()); |
| | | String errorMsg = CommonErrorEnum.getMsgByCode(eventsReceiver.getResult()); |
| | | log.error("Task progress ===> Error code: {},Error Msg: {}", eventsReceiver.getResult(),errorMsg); |
| | | } |
| | | |
| | | EventsResultStatusEnum statusEnum = EventsResultStatusEnum.find(output.getStatus()); |