|
@@ -127,7 +127,11 @@ public class MqttClientCallback implements MqttCallback, MqttCallbackExtended{
|
|
|
*/
|
|
|
@Override
|
|
|
public void messageArrived(String topic, MqttMessage message){
|
|
|
- log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>mqtt收到主题{}的消息:{}", topic, new String(message.getPayload()));
|
|
|
+ // 某个主题不打印
|
|
|
+ if(!"syn/strandnosize/receive".equals(topic)){
|
|
|
+ log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>mqtt收到主题{}的消息:{}", topic, new String(message.getPayload()));
|
|
|
+ }
|
|
|
+
|
|
|
// 通过原子类的自增方法来统计消息次数
|
|
|
messageCount.incrementAndGet();
|
|
|
try {
|