package com.yeshi.fanli.util.mq.cmq;
|
|
import com.google.gson.Gson;
|
import com.qcloud.cmq.Message;
|
import com.yeshi.fanli.dto.money.UserMoneyChangeDTO;
|
import com.yeshi.fanli.log.LogHelper;
|
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;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Component
|
public class UserMoneyChangeCMQManager {
|
|
@Resource
|
private RabbitTemplate rabbitTemplate;
|
|
|
private final static String TOPIC_NAME = "topic_user_money";
|
|
public static String QUEUE_DEBT = TOPIC_NAME + "_" + "debt";
|
|
public static String SUBSCRIBE_DEBT = "debt";
|
|
/**
|
* 发布
|
*
|
* @param dto
|
*/
|
public void addUserMoneyChangeMsg(UserMoneyChangeDTO dto) {
|
if (dto == null)
|
return;
|
RabbitmqSenderUtil.sendExchangeMsg(rabbitTemplate, TOPIC_NAME,"*", new Gson().toJson(dto) );
|
LogHelper.test("资金消息投递成功");
|
}
|
|
}
|
