我如何直接将消息发送到停车场队列，防止重新排队并退出程序流？

Question

我目前有4个队列：

• 测试队列
• 测试队列短期死信
• 测试队列长期死信
• 测试队列停车位

[当消息进入test-queue时，我进行检查以查看消息的格式是否正确。如果不是我想直接将消息发送到停车场队列。

我无法使用AmqpRejectAndDontRequeue()，因为它会自动将消息发送到已配置的DLQ（测试队列短期短期死信）。

将RabbitTemplate.convertAndSend()与另一个异常（例如BadRequestException）一起使用不起作用。该消息按预期到达停车场队列，但是相同的消息将保留在test-queue

中

单独使用RabbitTemplate.convertAndSend()，因为程序继续执行将无法使用。

所有队列都绑定到一个直接交换，每个交换都有唯一的路由密钥。 test-queue配置有以下参数：

• x-dead-letter-exchange: ""
• x-dead-letter-routing-key: <shortTermDeadLetterKey>

接收者：

  @RabbitListener(queues = "test-queue")
  public void receiveMessage(byte[] person) {
    String personString = new String(person);

    if (!personString.matches(desiredRegex)) {
      rabbitTemplate.convertAndSend("test-exchange", "test-queue-parking-lot",
          "invalid person");
      log.info("Invalid person");
    }
    ...some other code which I dont want to run as the message has arrived in the incorrect format
}

Answer 1

通过手动确认消息并从方法返回解决了问题。

  @RabbitListener(queues = "test-queue")
  public void receiveMessage(byte[] person, Channel channel,
  @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws Exception) {
    String personString = new String(person);

    if (!personString.matches(desiredRegex)) {
      rabbitTemplate.convertAndSend("test-exchange", "test-queue-parking-lot",
          "invalid person");
      log.info("Invalid person");
      channel.basicAck(tag, false);
      return;
    }
    ...some other code which I dont want to run as the message has arrived in the incorrect format
}