...
|
...
|
@@ -3,8 +3,6 @@ package com.yohoufo.order.service.handler; |
|
|
import com.google.common.eventbus.Subscribe;
|
|
|
import com.yohoufo.common.alarm.IEventHandler;
|
|
|
import com.yohoufo.order.event.BuyerOrderCancelShamDeliveryEvent;
|
|
|
import com.yohoufo.order.mq.DelayTime;
|
|
|
import com.yohoufo.order.mq.TopicConstants;
|
|
|
import com.yohoufo.order.mq.producer.TradeMqSender;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
...
|
...
|
@@ -26,9 +24,11 @@ public class BuyerOrderCancelShamDeliveryHandler implements IEventHandler<BuyerO |
|
|
@Override
|
|
|
@Subscribe
|
|
|
public void handle(BuyerOrderCancelShamDeliveryEvent event) {
|
|
|
int minutes = DelayTime.CANCEL_SHAM_DELIVERY_TIME_MINUTE ;
|
|
|
logger.info("Subscribe Buyer Order Cancel ShamDelivery Event delay msg, minutes {} ,event {}", minutes ,event);
|
|
|
logger.info("Subscribe Buyer Order Cancel ShamDelivery Event do nothing ,event {}", event);
|
|
|
|
|
|
tradeMqSender.send(TopicConstants.BUYER_ORDER_CANCEL_SHAM_DELIVER, event, minutes);
|
|
|
//int minutes = DelayTime.CANCEL_SHAM_DELIVERY_TIME_MINUTE ;
|
|
|
//logger.info("Subscribe Buyer Order Cancel ShamDelivery Event delay msg, minutes {} ,event {}", minutes ,event);
|
|
|
|
|
|
//tradeMqSender.send(TopicConstants.BUYER_ORDER_CANCEL_SHAM_DELIVER, event, minutes);
|
|
|
}
|
|
|
} |
...
|
...
|
|