package com.yeshi.fanli.util.mq.cmq.order;
|
|
import com.google.gson.Gson;
|
import com.yeshi.fanli.entity.bus.user.Order;
|
import com.yeshi.fanli.util.mq.rabbit.RabbitmqSenderUtil;
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
|
@Component
|
public class PlaceOrderCMQManager {
|
|
@Resource
|
private RabbitTemplate rabbitTemplate;
|
|
private final static String TOPIC_NAME = "topic_place_order";
|
|
public static String QUEUE_AD = TOPIC_NAME + "_" + "ad";
|
public static String QUEUE_INTEGRAL = TOPIC_NAME + "_" + "integral";
|
|
public static String SUBSCRIBE_AD = "ad";
|
public static String SUBSCRIBE_INTEGRAL = "integral";
|
|
/**
|
* 下单
|
*
|
* @param order（只需要订单号与sourceType）
|
*/
|
public void addPlaceOrderMsg(Order order) {
|
if (order == null)
|
return;
|
RabbitmqSenderUtil.sendExchangeMsg(rabbitTemplate, TOPIC_NAME, "*",new Gson().toJson(order));
|
}
|
|
}
|
