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);
|
}
|
}
|
