package com.yeshi.fanli.util.mq.cmq;
|
|
import com.google.gson.Gson;
|
import com.yeshi.fanli.dto.push.PushContentDetailDTO;
|
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 PushCMQManager {
|
|
@Resource
|
private RabbitTemplate rabbitTemplate;
|
|
|
public static String PUSH_HW = "push-hw";
|
|
static {
|
PUSH_HW += "-" + Constant.systemCommonConfig.getProjectName();
|
}
|
|
|
/**
|
* @param dto
|
*/
|
public void addHWPush(PushContentDetailDTO dto) {
|
if (dto == null)
|
return;
|
String json = new Gson().toJson(dto);
|
RabbitmqSenderUtil.sendQueueMsg(rabbitTemplate, PUSH_HW, json);
|
}
|
}
|
