Re: Semantics of timeout in asynchronous/one-way send methods

2017-04-23 Thread Zhanhui Li
Hi, folks, Any one? Any idea on this issue? Zhanhui Li. > 在 2017年4月17日,上午11:43,Zhanhui Li 写道: > > Hi, > > RocketMQ provides three message sending models: synchronous, asynchronous and > one-way. For asynchronous and one-way sending methods, internal > implementation employs semaphore to ens

Semantics of timeout in asynchronous/one-way send methods

2017-04-16 Thread Zhanhui Li
Hi, RocketMQ provides three message sending models: synchronous, asynchronous and one-way. For asynchronous and one-way sending methods, internal implementation employs semaphore to ensure client memory usage is properly bounded. The following code snippet reflects this idea: NettyRemoting