@Override
        public void onSuccess(SendResult sendResult) {
            System.out.println("成功");
        }

        @Override
        public void onException(OnExceptionContext onExceptionContext) {
            System.out.println("异常");
        }
    });
    /**
     * 事务
     */
    TimeUnit.SECONDS.sleep(2);
    msg.setName("事务消息======"+System.nanoTime());
    sdkTransactionNormalProducer.send(msg,(msg1,args)->{

        log.info("executed local transaction");
        return TransactionStatus.CommitTransaction;
    },null);
    /**
     * 延迟
     */
    msg.setName("延迟消息======"+System.nanoTime());
    sdkDelayProducer.sendAsync(msg, 5, new SendCallback() {
        @Override
        public void onSuccess(SendResult sendResult) {
            System.out.println("延迟成功");
        }

        @Override
        public void onException(OnExceptionContext onExceptionContext) {
            System.out.println("延迟异常");
        }
    });
    msg.setName("顺序消息======"+System.nanoTime());
    sdkOrderproducer.send(msg,"order");
}
 public void testTrans(){
     OrderTrans orderTrans=new OrderTrans();
     orderTrans.setId(UUID.randomUUID().toString());
     orderTrans.setTime(DateUtil.now());
     MsgOption msgOption=new MsgOption();
     msgOption.setTag("orderTrans");
     SendResult result=  sdkTransactionNormalProducer.send(orderTrans,msgOption,((message, o) -> {

         Boolean bln= local();
         if(bln){
             //成功就提交
             log.info("executed local transaction,发送消息成功");
             return TransactionStatus.CommitTransaction;

         }else{
             //如果失败就是回滚
             log.info("executed local transaction,发送消息失败");
             return TransactionStatus.RollbackTransaction;
         }

     }),null);
     System.out.println("发送的结果"+result);
 }
 @Transactional
public Boolean local(){
     Boolean bln=false;
    try {
        Random random=new Random();

        int i =random.nextInt(10) ;
        log.info("奇数"+i);
        if(i%2==0){
            log.info("偶数"+i);
            bln=true;
        }
    }catch (Exception exception){
        log.error("出问题了");
        bln=false;
    }
    return  bln;
}

@Autowired
private FinancialDivideBiz financialDivideBiz;
@Autowired
private FinancialDivideRefundBiz financialDivideRefundBiz;

@Override
public ConsumerAction message(MessageBody<Object> messageBody) {

	if (MsgOptionEnum.ORDER_EVENT_AFTER_SALES_APPLY.equals(messageBody.getOriginMessage().getTag())) {
		AfterSalesMessage body = BeanUtils.toBean(messageBody.getBody(), AfterSalesMessage.class);
		log.debug("接收到售后申请通知：" + JsonUtils.toJson(messageBody));

		DivideOrderRefundReq req = new DivideOrderRefundReq();
		req.setOrderId(String.valueOf(body.getSubId()));
		req.setRefundNo(body.getAfterSalesOrderSn());
		req.setRefundAmount(body.getReturnAmount());
		req.setSkuId(body.getSkuId());
		
		// 售后申请
		financialDivideRefundBiz.apply(req);

	} else if (MsgOptionEnum.ORDER_EVENT_AFTER_SALES_CLOSE.equals(messageBody.getOriginMessage().getTag())) {
		AfterSalesMessage body = BeanUtils.toBean(messageBody.getBody(), AfterSalesMessage.class);
		log.debug("接收到售后取消通知：" + JsonUtils.toJson(messageBody));

		// 售后申请
		financialDivideRefundBiz.cancle(body);

	} else if (MsgOptionEnum.ORDER_EVENT_NOTIFY_SETTLEMENT.equals(messageBody.getOriginMessage().getTag())) {
		OrderSubMessage body = BeanUtils.toBean(messageBody.getBody(), OrderSubMessage.class);
		log.debug("接收到普通订单完结通知：" + JsonUtils.toJson(messageBody));

		// 结算完结
		financialDivideBiz.complete(String.valueOf(body.getId()));

	}

	return ConsumerAction.SUCCESS;
}