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 {