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