package com.ycl.jxkg.rabbitmq.product;

import com.ycl.jxkg.rabbitmq.MyCorrelationData;
import com.ycl.jxkg.rabbitmq.RabbitMqMsgTypeEnum;
import lombok.RequiredArgsConstructor;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageProperties;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;

import java.nio.charset.StandardCharsets;

/**
 * @author：xp
 * @date：2024/6/28 11:18
 */
@Component
@RequiredArgsConstructor
public class Product {

    private final RabbitTemplate rabbitTemplate;

    public void examMsg() {
        // 设置消息的关联数据，以便发送确认回调、未路由成功消息的处理
        MyCorrelationData msgCorrelationData = new MyCorrelationData("ddddd", RabbitMqMsgTypeEnum.EXAM);
        rabbitTemplate.convertAndSend("examDlxQueue", (Object) "你好，RabbitMQ", msgCorrelationData);
    }

    public void meetMsg() {
        rabbitTemplate.convertAndSend("meetDlxQueue","你好，RabbitMQ");
    }

}