This is an automated email from the ASF dual-hosted git repository. rxl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
The following commit(s) were added to refs/heads/master by this push: new 77f0806 Fix send async comments (#254) 77f0806 is described below commit 77f0806b4a89418da4c72e4e15dbb9b200e74d58 Author: 冉小龙 <r...@apache.org> AuthorDate: Mon May 18 14:30:34 2020 +0800 Fix send async comments (#254) * Fix send async comments Signed-off-by: xiaolong.ran <r...@apache.org> * fix a little Signed-off-by: xiaolong.ran <r...@apache.org> * fix a little Signed-off-by: xiaolong.ran <r...@apache.org> * fix comments Signed-off-by: xiaolong.ran <r...@apache.org> --- pulsar/producer.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pulsar/producer.go b/pulsar/producer.go index 46103b5..a951426 100644 --- a/pulsar/producer.go +++ b/pulsar/producer.go @@ -128,6 +128,8 @@ type Producer interface { Send(context.Context, *ProducerMessage) (MessageID, error) // SendAsync a message in asynchronous mode + // This call is blocked when the `event channel` becomes full (default: 10) or the + // `maxPendingMessages` becomes full (default: 1000) // The callback will report back the message being published and // the eventual error in publishing SendAsync(context.Context, *ProducerMessage, func(MessageID, *ProducerMessage, error))