Authored by qinchao

测试mq时间

... ... @@ -31,6 +31,7 @@ public class BuyerMiniFaultOuterTimeHandler implements IEventHandler<BuyerMiniFa
@Subscribe
public void handle(BuyerMiniFaultOuterTimeEvent event) {
int minutes = DelayTime.MINI_FAULT_CONFIRM_OUTER_TIME_MINUTE;
minutes = 8;
logger.info("Subscribe Buyer mini fault delay msg, event {},minutes {}", event,minutes);
tradeMqSender.send(TopicConstants.BUYER_ORDER_MINI_FAULT_AUTO_REJECT, event,minutes );
... ...
... ... @@ -22,7 +22,7 @@ consumer:
- class: com.yohoufo.order.mq.consumer.BuyerOrderMiniFaultOuterTimeDelayMsgConsumer
topic: buyerOrder.miniFaultAutoReject
delay:
interval: 2880
interval: 8
#- class: com.yohoufo.order.mq.consumer.BuyerOrderCancelShamDeliveryMsgConsumer
# topic: buyerOrder.cancelShamDeliver
... ...