| | |
|---|
| | | @Override |
|---|
| | | public void handleMessage(Message<?> message) throws MessagingException { |
|---|
| | | MessageHeaders headers = message.getHeaders(); |
|---|
| | | log.info("线程名称：{}，收到消息，主题：{}，消息：{}", Thread.currentThread().getName(), headers.get("mqtt_receivedTopic").toString(), message.getPayload()); |
|---|
| | | log.error("线程名称：{}，收到消息，主题：{}，消息：{}", Thread.currentThread().getName(), headers.get("mqtt_receivedTopic").toString(), message.getPayload()); |
|---|
| | | // log.info("收到消息主题：{}", headers.get("mqtt_receivedTopic").toString()); |
|---|
| | | // log.info("收到消息：{}", message.getPayload()); |
|---|
| | | // 消息保存到内存队列里面，定时批量入库，也可以在这里直接入库 |
|---|
