feat(sj_1.0.0): 修复告警问题

snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/alarm/AbstractAlarm.java

@@ -33,6 +33,7 @@ import org.springframework.context.ApplicationListener;
 import org.springframework.scheduling.TaskScheduler;
 import org.springframework.transaction.event.TransactionPhase;
 import org.springframework.transaction.event.TransactionalApplicationListener;
+import org.springframework.transaction.event.TransactionalEventListener;
 import org.springframework.util.CollectionUtils;
 
 import java.time.Duration;
@@ -46,8 +47,7 @@ import java.util.stream.Collectors;
  * @since 2.5.0
  */
 @Slf4j
-public abstract class AbstractAlarm<E extends ApplicationEvent, A extends AlarmInfo> implements
-    TransactionalApplicationListener<E>,
+public abstract class AbstractAlarm<E extends ApplicationEvent, A extends AlarmInfo> implements ApplicationListener<E>,
     Runnable,
     Lifecycle {
 
@@ -223,11 +223,13 @@ public abstract class AbstractAlarm<E extends ApplicationEvent, A extends AlarmI
 
     protected abstract int getNotifyScene();
 
-    @NotNull
     @Override
-    public TransactionPhase getTransactionPhase() {
-        return TransactionPhase.AFTER_COMPLETION;
+    @TransactionalEventListener(fallbackExecution = true, phase = TransactionPhase.AFTER_COMPLETION)
+    public void onApplicationEvent(@NotNull E event) {
+        doOnApplicationEvent(event);
     }
+
+    protected abstract void doOnApplicationEvent(E event);
 }
 
 

snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/alarm/listener/JobTaskFailAlarmListener.java

@@ -106,7 +106,7 @@ public class JobTaskFailAlarmListener extends AbstractJobAlarm<JobTaskFailAlarmE
     }
 
     @Override
-    public void onApplicationEvent(JobTaskFailAlarmEvent event) {
+    public void doOnApplicationEvent(JobTaskFailAlarmEvent event) {
         if (!queue.offer(event.getJobTaskBatchId())) {
             SnailJobLog.LOCAL.warn("JOB任务执行失败告警队列已满");
         }

snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/alarm/listener/WorkflowTaskFailAlarmListener.java

@@ -88,7 +88,7 @@ public class WorkflowTaskFailAlarmListener extends AbstractWorkflowAlarm<Workflo
     }
 
     @Override
-    public void onApplicationEvent(WorkflowTaskFailAlarmEvent event) {
+    public void doOnApplicationEvent(WorkflowTaskFailAlarmEvent event) {
         if (!queue.offer(event.getWorkflowTaskBatchId())) {
             SnailJobLog.LOCAL.warn("Workflow任务执行失败告警队列已满");
         }

snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/listener/RetryTaskFailDeadLetterAlarmListener.java

@@ -65,7 +65,7 @@ public class RetryTaskFailDeadLetterAlarmListener extends
     }
 
     @Override
-    public void onApplicationEvent(RetryTaskFailDeadLetterAlarmEvent event) {
+    public void doOnApplicationEvent(RetryTaskFailDeadLetterAlarmEvent event) {
         if (!queue.offer(event.getRetryDeadLetters())) {
             SnailJobLog.LOCAL.warn("任务重试失败进入死信队列告警队列已满");
         }

snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/listener/RetryTaskFailMoreThresholdAlarmListener.java

@@ -64,7 +64,7 @@ public class RetryTaskFailMoreThresholdAlarmListener extends
     }
 
     @Override
-    public void onApplicationEvent(RetryTaskFailMoreThresholdAlarmEvent event) {
+    public void doOnApplicationEvent(RetryTaskFailMoreThresholdAlarmEvent event) {
         if (!queue.offer(event.getRetryTask())) {
             SnailJobLog.LOCAL.warn("任务失败数量超过阈值告警队列已满");
         }