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 29414db  [issue 574] Fix handle send error panic (#576)
29414db is described below

commit 29414db801a747672e6c0de62d0498d664e70d41
Author: cckellogg <[email protected]>
AuthorDate: Tue Jul 27 23:25:40 2021 -0700

    [issue 574] Fix handle send error panic (#576)
    
    Fix handle send error panic
---
 pulsar/internal/connection.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar/internal/connection.go b/pulsar/internal/connection.go
index 9873ec8..147de3f 100644
--- a/pulsar/internal/connection.go
+++ b/pulsar/internal/connection.go
@@ -752,7 +752,7 @@ func (c *connection) handleSendError(cmdError 
*pb.CommandError) {
 
        requestID := cmdError.GetRequestId()
 
-       switch *cmdError.Error {
+       switch cmdError.GetError() {
        case pb.ServerError_NotAllowedError:
                request, ok := c.deletePendingRequest(requestID)
                if !ok {

Reply via email to