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