You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rx...@apache.org on 2020/05/18 06:30:41 UTC
[pulsar-client-go] branch master updated: Fix send async comments
(#254)
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: 冉小龙 <rx...@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 <rx...@apache.org>
* fix a little
Signed-off-by: xiaolong.ran <rx...@apache.org>
* fix a little
Signed-off-by: xiaolong.ran <rx...@apache.org>
* fix comments
Signed-off-by: xiaolong.ran <rx...@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))