fix: 修复日志循环打印问题

pkg/jms/poll.go

@@ -29,8 +29,6 @@ func (p *PollJMSEvent) clearZombieSession() {
 	resp, err := grpc.GlobalGrpcClient.Client.ScanRemainReplays(ctx, req)
 	if err != nil || !resp.Status.Ok {
 		logger.GlobalLogger.Error("Failed to scan remain replay")
-	} else {
-		logger.GlobalLogger.Info("Scan remain replay success")
 	}
 }
 
@@ -40,17 +38,19 @@ func (p *PollJMSEvent) waitForKillSessionMessage() {
 		logger.GlobalLogger.Error("dispatch task err", zap.Error(err))
 		return
 	}
-	waitChan := make(chan struct{})
+	closeStreamChan := make(chan struct{})
 	for {
 		taskResponse, err := stream.Recv()
 		if err == io.EOF {
 			_ = stream.CloseSend()
-			close(waitChan)
+			close(closeStreamChan)
 			break
 		}
 		if err != nil {
 			logger.GlobalLogger.Error("Failed to receive a note", zap.Error(err))
-			continue
+			_ = stream.CloseSend()
+			close(closeStreamChan)
+			break
 		}
 
 		task := taskResponse.Task
@@ -75,7 +75,8 @@ func (p *PollJMSEvent) waitForKillSessionMessage() {
 			}
 		}
 	}
-	<-waitChan
+	<-closeStreamChan
+	p.waitForKillSessionMessage()
 }
 func (p *PollJMSEvent) sendFinishTask(stream protobuf.Service_DispatchTaskClient, TaskId string) {
 	req := &protobuf.FinishedTaskRequest{