This is an automated email from the ASF dual-hosted git repository.
jianbin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-seata-go.git
The following commit(s) were added to refs/heads/master by this push:
new 14341750 fix: fix heart beat bug (#749)
14341750 is described below
commit 14341750a781bccde3ab8f8f27bee7c40ea9a94c
Author: JayLiu <[email protected]>
AuthorDate: Sat Dec 21 19:40:52 2024 +0800
fix: fix heart beat bug (#749)
---
pkg/remoting/processor/client/client_heart_beat_processon.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/pkg/remoting/processor/client/client_heart_beat_processon.go
b/pkg/remoting/processor/client/client_heart_beat_processon.go
index c3822c54..b0ca3518 100644
--- a/pkg/remoting/processor/client/client_heart_beat_processon.go
+++ b/pkg/remoting/processor/client/client_heart_beat_processon.go
@@ -38,9 +38,9 @@ func (f *clientHeartBeatProcessor) Process(ctx
context.Context, rpcMessage messa
log.Debug("received PONG from {}", ctx)
}
}
- msgFuture :=
getty.GetGettyRemotingInstance().GetMessageFuture(rpcMessage.ID)
+ msgFuture :=
getty.GetGettyRemotingClient().GetMessageFuture(rpcMessage.ID)
if msgFuture != nil {
-
getty.GetGettyRemotingInstance().RemoveMessageFuture(rpcMessage.ID)
+
getty.GetGettyRemotingClient().RemoveMessageFuture(rpcMessage.ID)
}
return nil
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
