У меня есть очередь ActiveMQ, которая заполняется сообщениями от двух разных процессов. Первый снабжает очередь актуальными сообщениями, другой добавляет сообщение типа «keepAlive» в очередь каждые несколько секунд. Сообщения из этой очереди потребляются одним процессом с конечной точкой camel-netty.
Сообщение «keepAlive» необходимо отправлять только в том случае, если в данный период времени не отправляются другие сообщения. Вот почему я хочу изменить процесс «keepAlive», чтобы он заполнял очередь только тогда, когда в этой очереди нет других сообщений, удовлетворяющих определенным критериям (например, одно из значений заголовка равно чему-либо)
Это достижимо, используя только XML определение маршрута и процесса (без пользовательской реализации кода)?