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