Компонент Apache Camel JPA для нескольких потребительских сред, использует одно и то же сообщение

Я использую компонент Apache Camel JPA в качестве потребителя. Этот потребитель будет работать в среде с несколькими экземплярами. Теперь я хочу убедиться, что потребитель из каждого экземпляра не должен читать одни и те же записи, чтобы мне не приходилось обрабатывать одну и ту же запись дважды.

Я попытался использовать следующие параметры: ConsumerDelete=false - [Поскольку я не хочу, чтобы запись была удалена.] SkipLockedEntity=true

Насколько я понимаю, ConsumerLockEntity, значение которого по умолчанию равно true, должно предоставить мне ту возможность, которую я ищу.

Но в конечном итоге мне приходится обрабатывать мою запись несколько раз.

Любая помощь с примером будет высоко оценена.

0 ответов

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