Tag: rabbitmq

Spring RabbitMQ – 在具有@RabbitListener配置的服务上使用手动通道确认

如何在不使用自动确认的情况下手动确认消息。 有没有办法使用它与@RabbitListener和@EnableRabbit配置样式。 大多数文档告诉我们使用SimpleMessageListenerContainer和ChannelAwareMessageListener 。 但是使用它会失去注释提供的灵活性。 我已经配置了我的服务如下： @Service public class EventReceiver { @Autowired private MessageSender messageSender; @RabbitListener(queues = “${eventqueue}”) public void receiveMessage(Order order) throws Exception { // code for processing order } 我的RabbitConfiguration如下 @EnableRabbit public class RabbitApplication implements RabbitListenerConfigurer { public static void main(String[] args) { SpringApplication.run(RabbitApplication.class, args); } @Bean public MappingJackson2MessageConverter jackson2Converter() { MappingJackson2MessageConverter converter […]

RabbitMQ – 获取入队消息的总数

我有一个Java客户端监视RabbitMQ队列。 我能够使用此代码获取当前队列中的消息计数 @Resource RabbitAdmin rabbitAdmin; ………. DeclareOk declareOk = rabbitAdmin.getRabbitTemplate().execute(new ChannelCallback() { public DeclareOk doInRabbit(Channel channel) throws Exception { return channel.queueDeclarePassive(“test.pending”); } }); return declareOk.getMessageCount(); 我想获得更多其他细节，例如 – 当前排队项目的消息正文。 自创建队列以来在队列中排队的消息总数。 有没有办法在Java客户端中检索这些数据？