Camel SQS: расширение видимости не работает должным образом

Я использую Camel SQS для потребления сообщений в нашем приложении. Приложение пытается получить до 10 сообщений, но некоторые из этих сообщений могут занять больше времени, чем ожидалось, для обработки (дольше, чем установленный по умолчанию тайм-аут 20 секунд).

Когда я включаю расширение тайм-аута видимости, кажется, что это влияет только на текущее обрабатываемое сообщение - например, если у меня есть 10 сообщений, а первое сообщение занимает 30 секунд, оно больше не будет появляться в очереди - однако оставшиеся 9 сообщения будут.

Это ожидается, или это проблема с компонентом SQS? Я попытался обойти это, расширив SqsConsumer и установив TimeoutExtender в методе createExchanges, который решает мою проблему, однако это все еще "хакерское" исправление!

0 ответов

Другие вопросы по тегам