去掉demo队列
This commit is contained in:
parent
2806f817e6
commit
bb7728c025
@ -18,13 +18,5 @@ import java.io.IOException;
|
|||||||
@Component
|
@Component
|
||||||
@Slf4j
|
@Slf4j
|
||||||
public class YunxiListener {
|
public class YunxiListener {
|
||||||
@RabbitListener(queues = YunxiRabbitConst.QUEUE_YUNXI, containerFactory = "simpleRabbitListenerContainerFactory")
|
|
||||||
public void processYunxiQueue(Channel channel, Message message) throws IOException {
|
|
||||||
String messageContent = new String(message.getBody(), "UTF-8");
|
|
||||||
System.out.println("YunxiListener msg " + messageContent);
|
|
||||||
//TODO 消费者处理程序
|
|
||||||
|
|
||||||
//处理完毕 手动消息确认 配置需开启 acknowledge-mode: manual
|
|
||||||
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user