lrhkobe opened a new issue #378:
URL: https://github.com/apache/incubator-eventmesh/issues/378
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);**
}`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
