fix: fix heart beat bug (#749)

apache · Dec 21, 2024 · 1434175 · 1434175
1 parent cd8588e
commit 1434175
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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
 }