@@ -37,6 +37,7 @@ public class IotMessageListener implements MessageListener { | |||
// 如果业务处理耗时过程过长阻塞住线程,可能会影响SDK收到消息后的正常回调。 | |||
executorService.submit(() -> processMessage(message)); | |||
count++; | |||
log.info("count is : " + count); | |||
} catch (Exception e) { | |||
log.error("submit task occurs exception ", e); | |||
} | |||