wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-2616) - Starter 过滤实现增加调整

Browse Source
This commit is contained in:
wangli 2024-08-22 13:36:36 +08:00
parent fe1488f576
commit 608342cec5
5 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/handler/ProcessActivityEventHandler.java
View File

@ -25,7 +25,7 @@ public interface ProcessActivityEventHandler extends Ordered {
* @return
*/
default boolean accept(ProcessActivityDTO dto) {
return false;
return true;
}
/**

2
workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/broadcast/consumer/InnerActivityEventListener.java
View File

@ -65,7 +65,7 @@ public class InnerActivityEventListener extends AbstractInnerWorkflowListener<Pr
default:
log.warn("unknown process activity event type: {}", type);
}
if (!activityListener.filter(dto)) {
if (activityListener.accept(dto)) {
listenerExecutor.execute(consumer, context, dto);
}
}

2
workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/broadcast/consumer/InnerInstanceEventListener.java
View File

@ -68,7 +68,7 @@ public class InnerInstanceEventListener extends AbstractInnerWorkflowListener<Pr
default:
log.warn("unknown process activity event type: {}", type);
}
if (!instanceListener.filter(dto)) {
if (instanceListener.accept(dto)) {
listenerExecutor.execute(consumer, context, dto);
}
}

2
workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/broadcast/consumer/InnerNotificationEventListener.java
View File

@ -69,7 +69,7 @@ public class InnerNotificationEventListener extends AbstractInnerWorkflowListene
default:
log.warn("unknown message event type: {}", type);
}
if (!noticeListener.filter(dto)) {
if (noticeListener.accept(dto)) {
listenerExecutor.execute(consumer, context, dto);
}
}

2
workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/broadcast/consumer/InnerTaskEventListener.java
View File

@ -60,7 +60,7 @@ public class InnerTaskEventListener extends AbstractInnerWorkflowListener<Proces
default:
log.warn("unknown task event type: {}", type);
}
if (!taskListener.filter(dto)) {
if (taskListener.accept(dto)) {
listenerExecutor.execute(consumer, context, dto);
}
}