Мне нужна помощь с Java, Spring Boot, Apache Camel и Oracle Очередь.
В настоящее время у меня есть только очередь с сообщениями в Oracle, и я использую сообщения и отправляю каждое сообщение для функции с именем «processMessage», как показано в следующем коде:
from("oracleQueue:queue:" + queueName).process(new Processor() {
public void process(Exchange exchange) throws Exception {
}
}).bean(camelBean, "procesMessage").to("log:foo");
Но я должен сделать следующее: если одно из прочитанных сообщений имеет ошибку и отправляется в очередь исключений Мне нужно прекратить чтение сообщений из «главной очереди», и если «очередь исключений» пуста, я могу перечитать сообщения в «главной очереди».
Любая идея, как проверять каждый момент, есть ли в «очереди исключений» сообщения (или нет) и как остановить и начать чтение сообщений из «основной очереди», в зависимости от того, есть ли в «очереди исключений» сообщения или нет?
Спасибо вы.