|
@@ -4,9 +4,6 @@ import lombok.extern.slf4j.Slf4j;
|
|
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
|
|
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
|
|
import org.eclipse.paho.client.mqttv3.MqttCallback;
|
|
import org.eclipse.paho.client.mqttv3.MqttCallback;
|
|
import org.eclipse.paho.client.mqttv3.MqttMessage;
|
|
import org.eclipse.paho.client.mqttv3.MqttMessage;
|
|
-
|
|
|
|
-import static com.sun.deploy.util.ArrayUtil.arrayToString;
|
|
|
|
-
|
|
|
|
/**
|
|
/**
|
|
* @author zx
|
|
* @author zx
|
|
* @since 2024年11月13日
|
|
* @since 2024年11月13日
|
|
@@ -49,7 +46,7 @@ public class MqttConsumerCallBack implements MqttCallback {
|
|
@Override
|
|
@Override
|
|
public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
|
|
public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
|
|
log.info("发布完成客户端信息{}", iMqttDeliveryToken.getClient());
|
|
log.info("发布完成客户端信息{}", iMqttDeliveryToken.getClient());
|
|
- log.info("发布完成主题信息{}", arrayToString(iMqttDeliveryToken.getTopics()));
|
|
|
|
|
|
+ log.info("发布完成主题信息{}", (Object) iMqttDeliveryToken.getTopics());
|
|
log.info("发布完成消息id{}", iMqttDeliveryToken.getMessageId());
|
|
log.info("发布完成消息id{}", iMqttDeliveryToken.getMessageId());
|
|
|
|
|
|
}
|
|
}
|