推送MQ消息日志记录（log trace文件）

ibzdst-core/src/main/java/cn/ibizlab/core/extensions/util/DefaultMQProducerService.java

@@ -46,6 +46,7 @@ public class DefaultMQProducerService implements MsgProducerService{
     @Override
     public void sendEngineMsg(EngineMQMsg engineMQMsg)  {
         String msg = JSON.toJSONString(engineMQMsg);
+        log.trace(String.format("sendEngineMsg:%1$s", msg));
         dstRocketMQTemplate.asyncSendOrderly(ruleEngineTopic+":Engine",msg, DigestUtils.md5DigestAsHex(msg.getBytes()),new SendCallback(){
             @Override
             public void onSuccess(SendResult sendResult) {
@@ -64,6 +65,7 @@ public class DefaultMQProducerService implements MsgProducerService{
     @Override
     public void sendBuildMsg(EngineMQMsg engineMQMsg) {
         String msg = JSON.toJSONString(engineMQMsg);
+        log.trace(String.format("sendBuildMsg:%1$s", msg));
         dstRocketMQTemplate.asyncSendOrderly(ruleEngineTopic+":Build",msg, DigestUtils.md5DigestAsHex(msg.getBytes()),new SendCallback(){
             @Override
             public void onSuccess(SendResult sendResult) {
@@ -81,6 +83,7 @@ public class DefaultMQProducerService implements MsgProducerService{
     @Override
     public void sendResultsMsg(ResultsMQMsg resultsMQMsg) throws InterruptedException, RemotingException, MQClientException, MQBrokerException  {
         String msg = JSON.toJSONString(resultsMQMsg);
+        log.trace(String.format("sendResultsMsg:%1$s", msg));
         dstRocketMQTemplate.asyncSendOrderly(resultsTopic+":default",msg, DigestUtils.md5DigestAsHex(msg.getBytes()),new SendCallback(){
             @Override
             public void onSuccess(SendResult sendResult) {
@@ -98,9 +101,9 @@ public class DefaultMQProducerService implements MsgProducerService{
 
     @Override
     public void sendRuleResultsMsg(String topic, String tags, List<ExecResult> listExecResultMsg){
-
         try {
             String msg = JSON.toJSONString(listExecResultMsg);
+            log.trace(String.format("sendRuleResultsMsg:%1$s", msg));
             dstRocketMQTemplate.asyncSendOrderly(topic+":"+tags,msg, DigestUtils.md5DigestAsHex(msg.getBytes()),new SendCallback(){
                 @Override
                 public void onSuccess(SendResult sendResult) {
@@ -113,7 +116,6 @@ public class DefaultMQProducerService implements MsgProducerService{
                 }
 
             });
-
         } catch (Exception e) {
             e.printStackTrace();
             log.error("规则结果MQ主题：topic: {},tags: {},消息发送异常MQClientException: {}：", topic,tags,e);