大淘客搜索接口升级

admin

2020-11-28 dc5be7d38446f70e6ff86df311119c32b41fe7f8

 fanli/src/main/java/com/yeshi/fanli/service/manger/msg/RocketMQManager.java

@@ -77,7 +77,7 @@
         @Override

         public TransactionStatus execute(Message arg0, Object arg1) {

            if (mqEvent != null)

               mqEvent.excute();

               return mqEvent.excute( arg0,  arg1);

            return TransactionStatus.CommitTransaction;

         }

      }, null);

@@ -98,7 +98,7 @@
      sendTransactionalMsg(message, null, key, mqEvent);

   }



   interface ITransactionalMQEvent {

      public void excute();

   public interface ITransactionalMQEvent {

      public TransactionStatus excute(Message arg0, Object arg1);

   }

}