diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java index 41b0148a0..1f8ce8b9d 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java @@ -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())