File was renamed from src/main/java/com/ycl/jxkg/rabbitmq/product/Product.java |
| | |
| | | */ |
| | | @Component |
| | | @RequiredArgsConstructor |
| | | public class Product { |
| | | public class Producer { |
| | | |
| | | private final RabbitTemplate rabbitTemplate; |
| | | |
| | |
| | | rabbitTemplate.convertAndSend("examExchange", "exam", message, msgCorrelationData); |
| | | } |
| | | |
| | | public void meetMsg() { |
| | | rabbitTemplate.convertAndSend("meetDlxQueue","你好,RabbitMQ"); |
| | | public void meetMsg(Integer examId, String jsonMsg, Long delayTime) { |
| | | rabbitTemplate.convertAndSend("examExchange","meet", "你好,RabbitMQ"); |
| | | } |
| | | |
| | | } |