package org.springblade.modules.rabbitmq.config;

import org.springblade.modules.rabbitmq.redis.RedisService;
import org.springblade.modules.rabbitmq.vo.TaskMessage;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * 消息发送
 * @author zhongrj
 * @since 2022-04-12
 *
 */
@Service
public class MQsender {

    @Autowired
    AmqpTemplate amqpTemplate;


    public void send(Object message){
        String msg = RedisService.beanToString(message);
        amqpTemplate.convertAndSend(MQConfig.QUEUE,msg);
    }

	public void sendTaskMessage(TaskMessage message){
		String msg = RedisService.beanToString(message);
		amqpTemplate.convertAndSend(MQConfig.TASK_QUEUE,msg);
	}

    public void sendTopic(Object message){
        String msg = RedisService.beanToString(message);
        amqpTemplate.convertAndSend(MQConfig.TOPIC_EXCHANGE,"topic.key1",msg+"1");
    }

}