Delay queue optimization (2)

A new queue QC is added here, the binding relationship is as follows, the queue does not set TTL time

Configuration class file:

@Bean("queueC")public Queue queueC(){HashMap args = new HashMap();args.put("x-dead-letter-exchange",Y_DEAD_LETTER_EXCHANGE);args.put("x-dead-letter-routing-key","YD");// No TTL property declared herereturn QueueBuilder.durable(QUEUE_C).withArguments(args).build();}@Beanpublic Binding queueBindingX(@Qualifier("queueC") Queue queueC,@Qualifier("xExchange") DirectExchange exchange){return BindingBuilder.bind(queueC).to(exchange).with("XC");}

Producer:

@[email protected]("ttl")@RestControllerpublic class Produce01 {@Autowiredprivate RabbitTemplate rabbitTemplate;// @GetMapping("sendMsg/{message}")// public void sendMsg(@PathVariable String message)// {//// log.info("Current time: {}, send a message to two TTL queues: {}", new Date(), message);// rabbitTemplate.convertAndSend("X","XA","message from 10s"+message);// rabbitTemplate.convertAndSend("X","XB","The message comes from 40s"+message);// }@GetMapping("sendExpirationMsg/{message}/{ttlTime}")public void senMsg(@PathVariable String message,@PathVariable String ttlTime){log.info("Current time: {}, send a TTL message with duration {} milliseconds to queue C:{}", new Date(), ttlTime, message);rabbitTemplate.convertAndSend("X","XC",message, correlationData ->{correlationData.getMessageProperties().setExpiration(ttlTime);return correlationData;});}}

Consumer:

@[email protected] class Consumer {@RabbitListener(queues = "QD")public void receiveD(Message message, Channel channel){String s = new String(message.getBody());log.info("Current time{}, message received by dead letter queue D---->{}",new Date(),s);}}

p>

It doesn't seem to be a problem, but at the beginning, it was introduced that if you use the method of setting TTL on the message property, the message may not "die" on time, because RabbitMQ will only check the firstWhether the message is expired, if it expires, it will be thrown into the dead letter queue,

If the first message has a long delay and the second message has a short delay, the second message will not be executed first.