You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by "lizhimins (via GitHub)" <gi...@apache.org> on 2023/03/02 12:08:32 UTC

[GitHub] [rocketmq] lizhimins commented on issue #6205: LitePullConsumer support async pull message

lizhimins commented on issue #6205:
URL: https://github.com/apache/rocketmq/issues/6205#issuecomment-1451766305

   > > Does anyone want to try?
   > 
   > I want to try. but I don't know if I understood this correctly, just change the value of input parameter to async for pullKernelImpl method？
   
   This is actually a thread model problem. The implementation of synchronization is relatively simple, Each thread can use a loop to continuously obtain messages from the broker. For asynchronous pull, execute the next request in the callback of the last long poll. Please refer to the push consumer. 
   
   (click the avatar to get contact wx


-- 
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.

To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org