Spring Cloud Stream RabbitMQ оставить сообщение в очереди недоставленных сообщений - PullRequest
Новая
       29

Spring Cloud Stream RabbitMQ оставить сообщение в очереди недоставленных сообщений

0 голосов
/ 21 сентября 2019

Я использую облачные потоки Spring, чтобы получить сообщение от rabbitmq.Я пытаюсь получить сообщение с ошибкой, чтобы остаться в очереди недоставленных писем после нескольких попыток.Я программно сделал это перед использованием amqp, но, кажется, немного сложнее разобраться с весенними облачными потоками. 

@StreamListener(target = Sink.INPUT)
public void messageListener(final String in, @Header(name = "x-death", required = false) Map<?, ?> death) {

  if (!validString(in)) {
    // We don’t need this message anymore not even on the dlq
    throw new ImmediateAcknowledgeAmqpException(“String not good”);
  }

  // If message has been retried more than 3 time we want to put message on dlq
  if (death != null && death.get("count").equals(3L)) {
    // I know this is incorrect as it will ack the message, but at this point I need the message to be left on the dlq
    throw new ImmediateAcknowledgeAmqpException("Failed after 4 attempts");
  }

  try {
    // this trows an exception
    processService.process(in);
  }
  catch (Exception ex) {
    // here we retry the message
    throw new AmqpRejectAndDontRequeueException("retry message");
  }
}

Моя конфигурация 

spring.cloud.stream.bindings.input.destination=adestination
spring.cloud.stream.bindings.input.group=aqueue
spring.cloud.stream.rabbit.bindings.input.consumer.bindingRoutingKey=akey
#dlx/dlq setup
spring.cloud.stream.rabbit.bindings.input.consumer.deadLetterQueueName=adeadletterqueue
spring.cloud.stream.rabbit.bindings.input.consumer.dlqDeadLetterExchange=
spring.cloud.stream.rabbit.bindings.input.consumer.autoBindDlq=true
spring.cloud.stream.rabbit.bindings.input.consumer.requeueRejected=true
spring.cloud.stream.rabbit.bindings.input.consumer.dlqTtl=5000
# disable binder retries
spring.cloud.stream.bindings.input.consumer.max-attempts=1

Любая помощь очень ценится

Спасибо

1 Ответ

0 голосов
/ 23 сентября 2019

Вы не можете изменить отклоненное сообщение (например, добавив заголовок TTL).

Я полагаю, что вам придется вручную публиковать в очереди на парковку, когда повторные попытки исчерпаны.

...