ufo / yohoufo-fore · Commits

Go to a project

Authored by qinchao
Commit 89ef227e6ee5ac263bb20536803273ff684e6d9e 1 parent 57d8f105

mq时间test

Inline Side-by-side
Showing 2 changed files with 2 additions and 1 deletions
@@ -28,6 +28,7 @@ public class BuyerOrderSellerDeliveryCheckHandler implements IEventHandler<Buyer @@ -28,6 +28,7 @@ public class BuyerOrderSellerDeliveryCheckHandler implements IEventHandler<Buyer
28 public void handle(BuyerOrderSellerDeliveryCheckEvent event) { 28 public void handle(BuyerOrderSellerDeliveryCheckEvent event) {
29 logger.info("Subscribe Buyer Order Seller Delivery Event delay msg,event {}" ,event); 29 logger.info("Subscribe Buyer Order Seller Delivery Event delay msg,event {}" ,event);
30 int minutes = DelayTime.MINUTES_24_HOURS ; 30 int minutes = DelayTime.MINUTES_24_HOURS ;
  31 + minutes = 20;
31 tradeMqSender.send(TopicConstants.BUYER_ORDER_SELLER_DELIVERY_CHECK, event, minutes); 32 tradeMqSender.send(TopicConstants.BUYER_ORDER_SELLER_DELIVERY_CHECK, event, minutes);
32 } 33 }
33 } 34 }
@@ -29,7 +29,7 @@ consumer: @@ -29,7 +29,7 @@ consumer:
29 - class: com.yohoufo.order.mq.consumer.BuyerOrderSellerDeliveryCheckMsgConsumer 29 - class: com.yohoufo.order.mq.consumer.BuyerOrderSellerDeliveryCheckMsgConsumer
30 topic: buyerOrder.sellerDeliveryCheck 30 topic: buyerOrder.sellerDeliveryCheck
31 delay: 31 delay:
32 - interval: 1440 32 + interval: 20
33 33
34 - class: com.yohoufo.order.mq.consumer.BuyerOrderCancelShamDeliveryMsgConsumer 34 - class: com.yohoufo.order.mq.consumer.BuyerOrderCancelShamDeliveryMsgConsumer
35 topic: buyerOrder.cancelShamDeliver 35 topic: buyerOrder.cancelShamDeliver