fix code

2 years ago · ddb9354a19
parent 3e15c8b958
commit ddb9354a19
1 changed files with 4 additions and 3 deletions
--- 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);
+            });
        }
    }