大淘客与好单库与主包剥离

admin

2020-07-15 fe646416d8d46de7b896ddbf65a3ad0cd30b729b

 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);

   }

}