djl394922860 commented on issue #4602: URL: https://github.com/apache/rocketmq/issues/4602#issuecomment-1183936790
> @vergilyn IMO, depending on consumeExecutor's status is also not correct, consumeExecutor is still running, its status is always changing. if set awaitTerminationMillsWhenShutdown 0, ConsumeExecutor.awaitTermination method blocks until all tasks have completed execution after a shutdown request, or the current thread is interrupted. If user do not call thread.interrupt, it will keep waiting until all tasks have completed. ``` /** * Maximum time to await message consuming when shutdown consumer, 0 indicates no await. */ private long awaitTerminationMillisWhenShutdown = 0; ``` -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
