You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@eventmesh.apache.org by GitBox <gi...@apache.org> on 2021/06/01 06:24:40 UTC

[GitHub] [incubator-eventmesh] lrhkobe opened a new issue #378: downstream broadcast msg asynchronously

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:
users@infra.apache.org



---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: dev-help@eventmesh.apache.org

[GitHub] [incubator-eventmesh] xwm1992 closed issue #378: downstream broadcast msg asynchronously

Posted by GitBox <gi...@apache.org>.
xwm1992 closed issue #378:
URL: https://github.com/apache/incubator-eventmesh/issues/378


   


-- 
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:
users@infra.apache.org



---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: dev-help@eventmesh.apache.org