Блог

Используя компонент Apache Camel Twitter, моя программа получает обновления статуса от определенного пользователя. Я использую потребительский компонент.

Один запрос (ProducerTemplate.send()) вернет потенциально несколько обменов (по одному на статус).

Мой вопрос — есть ли способ добавить некоторую условную логику, основанную на количестве обменов, полученных с использованием Java DSL?

Возможно ли что-то вроде следующего псевдокода?

 from("twitter://user...")
    .choice()
        .when(simple("${exchanges.size()} >= 15"))
            .<do something here>
  

Текущий twitter не поддерживает отправку группы exchange на следующий процессор, поэтому ваш DSL не работает. Но если вы хотите обрабатывать обмен в группе, вы можете использовать aggregator для выполнения этой работы.