From 1c9c77c06b4251f1ccf0c2a6b8f280364adff787 Mon Sep 17 00:00:00 2001 From: imhao183 Date: Thu, 18 Mar 2021 18:27:37 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A4=9A=E4=BA=BA=E9=9F=B3=E8=A7=86=E9=A2=91?= =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=88=90=E5=91=98=E6=97=B6=E6=8E=A8=E9=80=81?= =?UTF-8?q?=E6=B6=88=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- broker/src/main/java/cn/wildfirechat/push/PushMessage.java | 2 +- .../src/main/java/io/moquette/spi/impl/MessagesPublisher.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/broker/src/main/java/cn/wildfirechat/push/PushMessage.java b/broker/src/main/java/cn/wildfirechat/push/PushMessage.java index 497c8b73..3df03f87 100644 --- a/broker/src/main/java/cn/wildfirechat/push/PushMessage.java +++ b/broker/src/main/java/cn/wildfirechat/push/PushMessage.java @@ -43,7 +43,7 @@ public class PushMessage { this.cntType = messageContentType; this.serverTime = serverTime; this.unReceivedMsg = unReceivedMsg; - if (cntType == 400) { + if (cntType == 400 || cntType == 406) { this.pushMessageType = PushServer.PushMessageType.PUSH_MESSAGE_TYPE_VOIP_INVITE; } else if(cntType == 402) { this.pushMessageType = PushServer.PushMessageType.PUSH_MESSAGE_TYPE_VOIP_BYE; diff --git a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java index ecf011f5..3d595974 100755 --- a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java +++ b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java @@ -332,7 +332,7 @@ public class MessagesPublisher { } } - if ((StringUtil.isNullOrEmpty(pushContent) && messageContentType != 402 && messageContentType != 400 && messageContentType != 401)) { + if ((StringUtil.isNullOrEmpty(pushContent) && messageContentType != 402 && messageContentType != 400 && messageContentType != 401 && messageContentType != 406)) { LOG.info("push content is empty and contenttype is {}", messageContentType); continue; }