|
@@ -122,8 +122,8 @@ public class SubMessageSendManager {
|
|
|
}
|
|
}
|
|
|
MessageBody messageBody = getMessageBody(subFunction);
|
|
MessageBody messageBody = getMessageBody(subFunction);
|
|
|
//仅发送一次
|
|
//仅发送一次
|
|
|
- if (redisService.getCacheObject(subId+"")==null){
|
|
|
|
|
- redisService.setCacheObject(subId+"",subId+"",15L, TimeUnit.SECONDS);
|
|
|
|
|
|
|
+ if (redisService.getCacheObject("onePcSubId"+subId)==null){
|
|
|
|
|
+ redisService.setCacheObject("onePcSubId"+subId,subId+"",15L, TimeUnit.SECONDS);
|
|
|
commonSend.send(getFunctionSubTopic(subId), messageBody, SendMode.ONCE);
|
|
commonSend.send(getFunctionSubTopic(subId), messageBody, SendMode.ONCE);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|