From ff60240ae049c3b8405a672695c6a2019d5934ad Mon Sep 17 00:00:00 2001 From: luky116 Date: Sat, 21 Dec 2024 19:18:15 +0800 Subject: [PATCH] fix heart beat bug --- 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 c3822c54a..b0ca35187 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 }