Java: Как вернуть статус задачи (или счетчик успеха) для программы, запущенной в кластерах? - PullRequest
Новая
       34

Java: Как вернуть статус задачи (или счетчик успеха) для программы, запущенной в кластерах?

0 голосов
/ 22 апреля 2020

Отправляем сообщение в очередь. Есть одна программа, развернутая на 3 серверах, которые читают из очереди.

Мы отправляем 15 000 сообщений и 5000, каждое из которых обрабатывается каждым сервером.

После всех окончаний sh, нам нужно показать в журнале "" ENC PROCESS ENDS "".

Как мы можем управлять этим в Java?

Примечание: Мы используем Apache Camel для этого, но я не могу понять, как этого добиться в общем Java ниже приведен верблюдный код для справки: 

Route 1: .marshal(new JaxbDataFormat(JAXBContext.newInstance(EmploymentUpdateRequest.class)))
            .inOnly(EMPLOYEES_QUEUE)
                    .choice()
                    .when(header("CamelSplitComplete"))
                        .log("Download xml file completed");

ROUTE 2: from(EMPLOYEES_QUEUE)
            .unmarshal(new JaxbDataFormat(JAXBContext.newInstance(EmploymentUpdateRequest.class)))
                .log("Extracting Data from Masterdata and Mapping")
                .bean("employeeService", "extract")

Маршрут 2 читает из очереди сотрудников, настроенной в wildfly.

...