wangli/nanopart
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-3300) - 添加 MQ 配置

Browse Source
This commit is contained in:
wangli 2025-01-17 16:23:52 +08:00
parent e556fbf701
commit e85882aecc
3 changed files with 123 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java
View File

@ -242,4 +242,26 @@ public class RocketMQEventConfiguration {
super.onEvent(message, eventConsumer);
}
}
/**
* 变洽签业务消费单据日志
*/
@Slf4j
@Component
@RocketMQMessageListener(topic = "topic_nanopart_${spring.profiles.active}",
consumerGroup = "GID_visa_change_log_${spring.application.name}_${spring.profiles.active}",
consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}"
)
public static class VisaChangeLogListener extends BaseListener implements RocketMQListener<MessageExt> {
@Autowired
private EventConsumer eventConsumer;
@Override
public void onMessage(MessageExt message) {
log.info("VisaChangeLogListener onMessage nanopart, message:{}", JSON.toJSONString(message));
super.onEvent(message, eventConsumer);
}
}
}

56
visa/visa-server/src/main/java/cn/axzo/visa/server/mq/listener/workflow/process/ProcessInstanceAllEventHandler.java Normal file
View File

@ -0,0 +1,56 @@
package cn.axzo.visa.server.mq.listener.workflow.process;
import cn.axzo.framework.rocketmq.Event;
import cn.axzo.framework.rocketmq.EventConsumer;
import cn.axzo.workflow.common.model.response.mq.ProcessInstanceDTO;
import cn.axzo.workflow.starter.handler.ProcessInstanceEventHandler;
import org.springframework.stereotype.Component;
/**
* 工作流广播的实例维度的所有事件类型
*
* @author wangli
* @since 2025-01-17 11:35
*/
@Component
public class ProcessInstanceAllEventHandler implements ProcessInstanceEventHandler {
@Override
public int getOrder() {
return Integer.MIN_VALUE;
}
@Override
public boolean accept(ProcessInstanceDTO dto, Event event, EventConsumer.Context context) {
return ProcessInstanceEventHandler.super.accept(dto, event, context);
}
@Override
public void onCreated(ProcessInstanceDTO dto) {
ProcessInstanceEventHandler.super.onCreated(dto);
}
@Override
public void onStarted(ProcessInstanceDTO dto) {
ProcessInstanceEventHandler.super.onStarted(dto);
}
@Override
public void onCompleted(ProcessInstanceDTO dto) {
ProcessInstanceEventHandler.super.onCompleted(dto);
}
@Override
public void onCancelled(ProcessInstanceDTO dto) {
ProcessInstanceEventHandler.super.onCancelled(dto);
}
@Override
public void onRejected(ProcessInstanceDTO dto) {
ProcessInstanceEventHandler.super.onRejected(dto);
}
@Override
public void onAborted(ProcessInstanceDTO dto) {
ProcessInstanceEventHandler.super.onAborted(dto);
}
}

45
visa/visa-server/src/main/java/cn/axzo/visa/server/mq/listener/workflow/task/ProcessTaskAllEventHandler.java Normal file
View File

@ -0,0 +1,45 @@
package cn.axzo.visa.server.mq.listener.workflow.task;
import cn.axzo.framework.rocketmq.Event;
import cn.axzo.framework.rocketmq.EventConsumer;
import cn.axzo.workflow.common.model.response.mq.ProcessTaskDTO;
import cn.axzo.workflow.starter.handler.ProcessTaskEventHandler;
import io.swagger.models.auth.In;
/**
* 工作流广播的任务维度的所有事件类型
*
* @author wangli
* @since 2025-01-17 11:34
*/
public class ProcessTaskAllEventHandler implements ProcessTaskEventHandler {
@Override
public int getOrder() {
return Integer.MAX_VALUE;
}
@Override
public boolean accept(ProcessTaskDTO dto, Event event, EventConsumer.Context context) {
return ProcessTaskEventHandler.super.accept(dto, event, context);
}
@Override
public void onAssigned(ProcessTaskDTO dto) {
ProcessTaskEventHandler.super.onAssigned(dto);
}
@Override
public void onCreated(ProcessTaskDTO dto) {
ProcessTaskEventHandler.super.onCreated(dto);
}
@Override
public void onCompleted(ProcessTaskDTO dto) {
ProcessTaskEventHandler.super.onCompleted(dto);
}
@Override
public void onDeleted(ProcessTaskDTO dto) {
ProcessTaskEventHandler.super.onDeleted(dto);
}
}