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

update - 移除大对象的数据日志打印

Browse Source
This commit is contained in:
wangli 2023-12-08 09:55:20 +08:00
parent cd560d3924
commit 842552a4f0
1 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java
View File

@ -51,8 +51,7 @@ public class RocketMqBpmnProcessEventListener implements BpmnProcessEventListene
@Override
public void onCreated(FlowableEngineEntityEvent event) {
if (log.isDebugEnabled()) {
log.debug("RocketMQ onCreated: ClassName: {}, event: {}", event.getClass().getName(),
JSON.toJSONString(event));
log.debug("RocketMQ onCreated: ClassName: {}", event.getClass().getName());
}
Deployment deployment =
repositoryService.createDeploymentQuery().deploymentId(((ExecutionEntityImpl) event.getEntity()).getDeploymentId()).singleResult();
@ -82,8 +81,7 @@ public class RocketMqBpmnProcessEventListener implements BpmnProcessEventListene
@Override
public void onStarted(FlowableProcessStartedEvent event) {
if (log.isDebugEnabled()) {
log.debug("RocketMQ onStarted: ClassName: {}, event: {}", event.getClass().getName(),
JSON.toJSONString(event));
log.debug("RocketMQ onStarted: ClassName: {}", event.getClass().getName());
}
Deployment deployment =
repositoryService.createDeploymentQuery().deploymentId(((ExecutionEntityImpl) event.getEntity()).getDeploymentId())
@ -115,8 +113,7 @@ public class RocketMqBpmnProcessEventListener implements BpmnProcessEventListene
@Override
public void onCancelled(FlowableCancelledEvent event) {
if (log.isDebugEnabled()) {
log.debug("RocketMQ onCancelled: ClassName: {}, event: {}", event.getClass().getName(),
JSON.toJSONString(event));
log.debug("RocketMQ onCancelled: ClassName: {}", event.getClass().getName());
}
Deployment deployment =
repositoryService.createDeploymentQuery().deploymentId(((ExecutionEntityImpl) ((FlowableProcessCancelledEventImpl) event).getExecution()).getDeploymentId())
@ -152,8 +149,7 @@ public class RocketMqBpmnProcessEventListener implements BpmnProcessEventListene
@Override
public void onRejected(FlowableCancelledEvent event) {
if (log.isDebugEnabled()) {
log.debug("RocketMQ onRejected: ClassName: {}, event: {}", event.getClass().getName(),
JSON.toJSONString(event));
log.debug("RocketMQ onRejected: ClassName: {}", event.getClass().getName());
}
Deployment deployment =
repositoryService.createDeploymentQuery().deploymentId(((ExecutionEntityImpl) ((FlowableProcessCancelledEventImpl) event).getExecution()).getDeploymentId())
@ -184,8 +180,7 @@ public class RocketMqBpmnProcessEventListener implements BpmnProcessEventListene
@Override
public void onCompleted(FlowableEngineEntityEvent event) {
if (log.isDebugEnabled()) {
log.debug("RocketMQ onCompleted: ClassName: {}, event: {}", event.getClass().getName(),
JSON.toJSONString(event));
log.debug("RocketMQ onCompleted: ClassName: {}", event.getClass().getName());
}
Deployment deployment =
repositoryService.createDeploymentQuery().deploymentId(((ExecutionEntityImpl) event.getEntity()).getDeploymentId())