downstream broadcast msg asynchronously #378
Description
When downstreaming broadcast messages, blocking of one client may affect the consumption of other clients.So maybe we can make it asynchronously.
while (sessionsItr.hasNext()) {
Session session = sessionsItr.next();
if (!session.isAvailable(topic)) {
logger.warn("downstream broadcast msg,session is not available,client:{}", session.getClient());
continue;
}
downStreamMsgContext.session = session;
//msg put in eventmesh,waiting client ack
session.getPusher().unAckMsg(downStreamMsgContext.seq, downStreamMsgContext);
session.downstreamMsg(downStreamMsgContext);
}