|
@ -58,8 +58,7 @@ public class MQTTClientUtil {
|
|
@Override
|
|
@Override
|
|
public void messageArrived(String s, MqttMessage message) throws Exception {
|
|
public void messageArrived(String s, MqttMessage message) throws Exception {
|
|
// subscribe后得到的消息会执行到这里面
|
|
// subscribe后得到的消息会执行到这里面
|
|
logger.info("接收s : " + s);
|
|
|
|
logger.info("接收消息主题 : " + message);
|
|
|
|
|
|
logger.info("接收消息主题 : " + s);
|
|
logger.info("接收消息Qos : " + message.getQos());
|
|
logger.info("接收消息Qos : " + message.getQos());
|
|
logger.info("接收消息内容 : " + new String(message.getPayload()));
|
|
logger.info("接收消息内容 : " + new String(message.getPayload()));
|
|
|
|
|