|
@@ -553,7 +553,7 @@ public class PushMessage implements Serializable {
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- resetUserIds(pushUserInfos);
|
|
|
+ resetUsers(pushUserInfos);
|
|
|
if (IterUtil.isNotEmpty(toAndroid)) {
|
|
|
this.setToList(new ArrayList<>(toAndroid));
|
|
|
jmsMessagingTemplate.send(ValuePool.PUSH_QUEUE_ANDROID_TOKEN, new GenericMessage<>(this));
|
|
@@ -581,7 +581,7 @@ public class PushMessage implements Serializable {
|
|
|
if (!pushUserInfo.available()) {
|
|
|
return false;
|
|
|
}
|
|
|
- resetUserIds(pushUserInfo);
|
|
|
+ resetUsers(pushUserInfo);
|
|
|
this.add(pushUserInfo.getDeviceFlag());
|
|
|
if (pushUserInfo.isAndroid()) {
|
|
|
jmsMessagingTemplate.send(ValuePool.PUSH_QUEUE_ANDROID_TOKEN, new GenericMessage<>(this));
|
|
@@ -615,7 +615,7 @@ public class PushMessage implements Serializable {
|
|
|
* 将用户id和设备类型传到消息中间件中,方便消息中心功能来保存
|
|
|
* @param pushUserInfos 用户信息列表
|
|
|
*/
|
|
|
- private void resetUserIds(List<PushUserInfo> pushUserInfos) {
|
|
|
+ private void resetUsers(List<PushUserInfo> pushUserInfos) {
|
|
|
users.clear();
|
|
|
pushUserInfos.forEach(pushUserInfo -> users.put(pushUserInfo.getUserId(),pushUserInfo.getDeviceModel()));
|
|
|
}
|
|
@@ -623,7 +623,7 @@ public class PushMessage implements Serializable {
|
|
|
* 将用户id和设备类型传到消息中间件中,方便消息中心功能来保存
|
|
|
* @param pushUserInfo 用户信息列表
|
|
|
*/
|
|
|
- private void resetUserIds(PushUserInfo pushUserInfo) {
|
|
|
+ private void resetUsers(PushUserInfo pushUserInfo) {
|
|
|
users.clear();
|
|
|
users.put(pushUserInfo.getUserId(),pushUserInfo.getDeviceModel());
|
|
|
}
|