This is an automated email from the ASF dual-hosted git repository.

tison 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 443072bf [Improve] Update connection.lastDataReceivedTime when it is 
ready (#1145)
443072bf is described below

commit 443072bf5151283e412fd9191c6efdc527bc5816
Author: gunli <[email protected]>
AuthorDate: Wed Dec 27 17:32:25 2023 +0800

    [Improve] Update connection.lastDataReceivedTime when it is ready (#1145)
    
    Co-authored-by: gunli <[email protected]>
---
 pulsar/internal/connection.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pulsar/internal/connection.go b/pulsar/internal/connection.go
index 840ecc4f..cb8c680d 100644
--- a/pulsar/internal/connection.go
+++ b/pulsar/internal/connection.go
@@ -338,6 +338,7 @@ func (c *connection) doHandshake() bool {
                c.maxMessageSize = MaxMessageSize
        }
        c.log.Info("Connection is ready")
+       c.setLastDataReceived(time.Now())
        c.changeState(connectionReady)
        return true
 }

Reply via email to