MQ配置查看

src/main/java/com/uas/erp/schedular/entity/MqConfig.java

@@ -64,4 +64,17 @@ public class MqConfig {
     public void setMa_mqqueuename(String ma_mqqueuename) {
         this.ma_mqqueuename = ma_mqqueuename;
     }
+
+    @Override
+    public String toString() {
+        return "MqConfig{" +
+                "ma_mqdynamiccreate=" + ma_mqdynamiccreate +
+                ", ma_mqhost='" + ma_mqhost + '\'' +
+                ", ma_mqport=" + ma_mqport +
+                ", ma_mqvirtualhost='" + ma_mqvirtualhost + '\'' +
+                ", ma_mqusername='" + ma_mqusername + '\'' +
+                ", ma_mqpassword='" + ma_mqpassword + '\'' +
+                ", ma_mqqueuename='" + ma_mqqueuename + '\'' +
+                '}';
+    }
 }

src/main/java/com/uas/erp/schedular/finance/mq/RabbitReceiveServiceImpl.java

@@ -53,8 +53,9 @@ public class RabbitReceiveServiceImpl extends BaseRabbitReceiveService {
         try {
             mqConfig = jdbcTemplate.queryForBean("select MA_MQDYNAMICCREATE ,MA_MQHOST, MA_MQPORT, MA_MQVIRTUALHOST, MA_MQUSERNAME, MA_MQPASSWORD, MA_MQQUEUENAME from master where ma_user='" + MASTERNAME + "'", MqConfig.class);
         }catch (Exception e){
-
+            e.printStackTrace();
         }
+        logger.debug("MQ配置："+mqConfig.toString());
         if(mqConfig != null){
             isDynamicCreate = mqConfig.isMa_mqdynamiccreate();
             host = mqConfig.getMa_mqhost();