|
@@ -1,24 +0,0 @@
|
|
|
-package com.pj.rabbitmq.listener;
|
|
|
-
|
|
|
-import com.pj.rabbitmq.config.RabbitMqConfig;
|
|
|
-import com.pj.tb_people.TbPeople;
|
|
|
-import org.springframework.amqp.rabbit.annotation.Queue;
|
|
|
-import org.springframework.amqp.rabbit.annotation.RabbitHandler;
|
|
|
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
|
|
-import org.springframework.stereotype.Component;
|
|
|
-
|
|
|
-/**
|
|
|
- * @Author Mechrevo
|
|
|
- * @Date 2023 07 28 17 12
|
|
|
- **/
|
|
|
-@Component
|
|
|
-public class PeopleRabbitMQListener {
|
|
|
-
|
|
|
-
|
|
|
- @RabbitHandler
|
|
|
- @RabbitListener(queuesToDeclare = @Queue(RabbitMqConfig.PEOPLE_REVEIVE_MESSAGE_MQ))
|
|
|
- public void consumerPeople(TbPeople tbPeople){
|
|
|
- //todo:开始执行发送短信
|
|
|
- System.out.println("peopleId = " + tbPeople.getId().toString() + "\n");
|
|
|
- }
|
|
|
-}
|