From ddb9354a19fdd7b8a7775f1bcf3149f4f6b4f40a Mon Sep 17 00:00:00 2001
From: diaobisong <bitdbsd11@163.com>
Date: Fri, 22 Mar 2024 11:48:38 +0800
Subject: [PATCH] fix code

---
 .../handler/receiver/service/impl/ConsumeServiceImpl.java  | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/impl/ConsumeServiceImpl.java b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/impl/ConsumeServiceImpl.java
index 905e344..26b0509 100644
--- a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/impl/ConsumeServiceImpl.java
+++ b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/impl/ConsumeServiceImpl.java
@@ -64,9 +64,10 @@ public class ConsumeServiceImpl implements ConsumeService {
             taskInfo.setAnchorInfo(info);
             logUtils.print(LogParam.builder().bizType(LOG_BIZ_TYPE).object(taskInfo).build(), info);
             Task task = context.getBean(Task.class).setTaskInfo(taskInfo);
-            taskPendingHolder.route(topicGroupId).execute(task);
-
-            realTimeData(info);
+            taskPendingHolder.route(topicGroupId).execute(() -> {
+                task.run();
+                realTimeData(info);
+            });
         }
     }