From f81e6574a932904989e0291150d4ec23604315dc Mon Sep 17 00:00:00 2001
From: wangxianzhang <ZHANGYUGE6666>
Date: Mon, 27 Dec 2021 13:40:00 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=EF=BC=9A=20BlockChian=20prod?=
 =?UTF-8?q?ucer=EF=BC=8C=E5=A2=9E=E5=8A=A0=E5=AF=B9enable=E6=A0=87?=
 =?UTF-8?q?=E5=BF=97=E7=9A=84=E5=88=A4=E6=96=AD=EF=BC=8C=E5=86=B3=E5=AE=9A?=
 =?UTF-8?q?=E6=98=AF=E5=90=A6=E5=90=AF=E7=94=A8BC=E7=9A=84mq=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF=E7=94=9F=E4=BA=A7=E8=80=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/epmet/mq/producer/BlockChainProducer.java  | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/mq/producer/BlockChainProducer.java b/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/mq/producer/BlockChainProducer.java
index 3ec172b7a6..46c83b7e4e 100644
--- a/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/mq/producer/BlockChainProducer.java
+++ b/epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/mq/producer/BlockChainProducer.java
@@ -57,6 +57,13 @@ public class BlockChainProducer {
     @PostConstruct
     private void postConstruct() {
         try {
+            
+            // 如果没有启用，则跳过
+            if (!rocketMQProperties.getBlockChain().getEnable()) {
+                log.info("未开启区块链的MQ配置，初始化Producer动作取消");
+                return;
+            }
+            
             producer = new DefaultMQProducer(GROUP_EPMET_CLOUD_PROJECT_SENDER,
                     new AclClientRPCHook(new SessionCredentials(rocketMQProperties.getBlockChain().getAccessKey(), rocketMQProperties.getBlockChain().getSecretKey())));
             producer.setNamesrvAddr(rocketMQProperties.getBlockChain().getNameServer());
@@ -82,6 +89,13 @@ public class BlockChainProducer {
      */
     public void sendMsg(String topic, String tag, String content) {
         try {
+
+            // 如果没有启用，则跳过
+            if (!rocketMQProperties.getBlockChain().getEnable()) {
+                log.info("未开启区块链的MQ配置，发送消息到区块链动作取消");
+                return;
+            }
+            
             Message msg = new Message(topic, tag, content.getBytes(RemotingHelper.DEFAULT_CHARSET));
             SendResult sendResult = producer.send(msg);
             if (SendStatus.SEND_OK == sendResult.getSendStatus()