package com.ycl.jxkg.rabbitmq.consumer; import org.springframework.amqp.rabbit.annotation.*; import org.springframework.stereotype.Component; /** * @author:xp * @date:2024/6/28 11:51 */ @Component public class Consumer { /** * 考试状态更新的消费者 * * @param message */ @RabbitListener(queues = "examDlxQueue") public void examStatusAdjustConsumer(String message){ System.out.println(message); } /** * 会议消费者 * * @param message */ @RabbitListener(queues = "meetDlxQueue") public void meetConsumer(String message){ System.out.println(message); } }