package com.yeshi.fanli.util.mq.cmq.order;
|
|
import com.google.gson.Gson;
|
import com.yeshi.fanli.dto.mq.order.body.CommonOrderMQMsg;
|
import com.yeshi.fanli.util.Constant;
|
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 OrdersCMQManager {
|
|
@Resource
|
private RabbitTemplate rabbitTemplate;
|
|
public static String ORDER_ALL = "order-all";
|
|
static {
|
ORDER_ALL += "-" + Constant.systemCommonConfig.getProjectName();
|
}
|
|
|
/**
|
* 添加订单到队列
|
*
|
* @param msg
|
*/
|
public void addOrder(CommonOrderMQMsg msg) {
|
RabbitmqSenderUtil.sendQueueMsg(rabbitTemplate, ORDER_ALL, new Gson().toJson(msg));
|
}
|
|
|
}
|
