|
@ -94,7 +94,7 @@ public class PushMsgTask {
|
|
|
while (true) {
|
|
|
// 如果queue为空,则当前线程会堵塞,直到有新数据加入
|
|
|
JSONObject json = queue.take();
|
|
|
System.out.println("发送前:"+json);
|
|
|
logger.info("发送前:"+json);
|
|
|
// 推送平台消息
|
|
|
String receiver = json.containsKey("receiver") ? json.getString("receiver") : "";
|
|
|
String type = json.containsKey("type") ? json.getString("type") : "";
|