From 06698a54e117d44633430ab487ee87a3c44df343 Mon Sep 17 00:00:00 2001 From: heavyrain lee Date: Fri, 26 Apr 2019 08:12:38 +0800 Subject: [PATCH] =?UTF-8?q?Server=20api=E5=8F=91=E9=80=81=E6=B6=88?= =?UTF-8?q?=E6=81=AF=E6=97=B6=EF=BC=8C=E5=BF=85=E9=A1=BB=E5=B8=A6=E4=B8=8A?= =?UTF-8?q?=E5=8F=91=E9=80=81=E8=80=85?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/xiaoleilu/loServer/action/admin/SendMessageAction.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/broker/src/main/java/com/xiaoleilu/loServer/action/admin/SendMessageAction.java b/broker/src/main/java/com/xiaoleilu/loServer/action/admin/SendMessageAction.java index afc32a84..2442c526 100755 --- a/broker/src/main/java/com/xiaoleilu/loServer/action/admin/SendMessageAction.java +++ b/broker/src/main/java/com/xiaoleilu/loServer/action/admin/SendMessageAction.java @@ -10,6 +10,7 @@ package com.xiaoleilu.loServer.action.admin; import com.google.gson.Gson; +import com.hazelcast.util.StringUtil; import com.xiaoleilu.loServer.RestResult; import com.xiaoleilu.loServer.annotation.HttpMethod; import com.xiaoleilu.loServer.annotation.Route; @@ -41,7 +42,7 @@ public class SendMessageAction extends AdminAction { public void action(Request request, Response response) { if (request.getNettyRequest() instanceof FullHttpRequest) { SendMessageData sendMessageData = getRequestBody(request.getNettyRequest(), SendMessageData.class); - if (SendMessageData.isValide(sendMessageData)) { + if (SendMessageData.isValide(sendMessageData) && !StringUtil.isNullOrEmpty(sendMessageData.getSender())) { RPCCenter.getInstance().sendRequest(sendMessageData.getSender(), null, IMTopic.SendMessageTopic, sendMessageData.toProtoMessage().toByteArray(), sendMessageData.getSender(), TargetEntry.Type.TARGET_TYPE_USER, new RPCCenter.Callback() { @Override public void onSuccess(byte[] result) {