AutoLack Camel AMQP не удалось разрешить конечную точку - PullRequest
Новая
       22

AutoLack Camel AMQP не удалось разрешить конечную точку

0 голосов
/ 11 сентября 2018

Я пытаюсь установить для autoAck значение false при чтении из очереди служебной шины Azure, к которой я подключаюсь с помощью amqp.Ниже приведен код. 

from("amqp:queue:testqueue?autoAck=false&concurrentConsumers=1")

Но я получаю сообщение об ошибке: 

Failed to create route route1: Route(route1)[[From[amqp:queue:testqueue?autoAck=false&concu... because of Failed to resolve endpoint: amqp://queue:testqueue?autoAck=false&concurrentConsumers=1 due to: Failed to resolve endpoint: amqp://queue:testqueue?autoAck=false&concurrentConsumers=1 due to: There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{autoAck=false}]

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

1 Ответ

0 голосов
/ 11 сентября 2018

Я наконец-то нашел ответ, чтобы удалять сообщения из очереди только тогда, когда потребитель принял сообщение и подтвердил, что оно было успешно обработано, вам нужно добавить «cknowledgementModeName »к маршруту 

from("amqp:queue:testqueue?acknowledgementModeName=CLIENT_ACKNOWLEDGE&concurrentConsumers=1")

Для получения дополнительной информации посетите эту страницу http://camel.apache.org/jms.html

...