Библиотека ecos-camel-core

Библиотека является надстройкой над Apache Camel, которая адаптирована для работы с платформой Citeck.

Примечание

Для работы с библиотекой необходима enterprise лицензия.

Подключение

Добавьте зависимость в нужном микросервисе:

<dependency>
    <groupId>ru.citeck.ecos.ent.camel</groupId>
    <artifactId>ecos-camel-core</artifactId>
</dependency>

Подходящая версия будет загружена из родительского POM.

Пример использования

Создайте компонент с настройками роутов. Он запустит новый контекст после старта приложения:

package ru.citeck.ecos.webapp.demo;

import jakarta.annotation.PostConstruct;
import kotlin.Unit;
import lombok.RequiredArgsConstructor;
import lombok.SneakyThrows;
import org.apache.camel.Endpoint;
import org.apache.camel.builder.RouteBuilder;
import org.apache.groovy.util.Maps;
import org.springframework.beans.factory.DisposableBean;
import org.springframework.stereotype.Component;
import ru.citeck.ecos.camel.context.EcosCamelContext;
import ru.citeck.ecos.camel.context.EcosCamelContextFactory;
import ru.citeck.ecos.commons.data.DataValue;
import ru.citeck.ecos.records2.predicate.model.Predicates;
import ru.citeck.ecos.webapp.api.EcosWebAppApi;

@Component
@RequiredArgsConstructor
public class EcosCamelExample extends RouteBuilder implements DisposableBean {

    // для базовой работы нужны два бина:
    private final EcosWebAppApi ecosWebAppApi;           // запуск после инициализации приложения
    private final EcosCamelContextFactory contextFactory; // создание нового контекста

    // ссылку на контекст сохраняем в поле для последующей остановки
    private EcosCamelContext context = null;

    @SneakyThrows
    @PostConstruct
    public void init() {
        // создаём и запускаем контекст только после инициализации приложения
        ecosWebAppApi.doBeforeAppReady(0, () -> {
            createAndStartContext();
            return Unit.INSTANCE;
        });
    }

    @SneakyThrows
    private void createAndStartContext() {
        // создаём новый контекст и регистрируем роуты
        context = contextFactory.createContext().build();
        context.addRoutes(this);
        context.start();
    }

    @Override
    public void configure() {

        // endpoint для прослушивания событий ECOS с типом "record-created"
        // и фильтром по типу записей "demo-type"
        Endpoint endpoint = getContext().getEndpoint(
            "ecos-event:record-created",
            Maps.of(
                "attributes", Maps.of(
                    "recordRef", "record?id",
                    "id",        "record?localId",
                    "name",      "record?disp",
                    "textField", "record.textField"
                ),
                "filter",        Predicates.eq("typeDef.id", "demo-type"),
                "transactional", true
            )
        );

        from(endpoint)
            .to("log:after-event-received")
            .process(exchange -> {
                DataValue body = exchange.getMessage().getBody(DataValue.class);

                DataValue newBody = DataValue.createObj();
                newBody.set("id",        body.get("id"));
                newBody.set("name",      body.get("name"));
                newBody.set("textField", body.get("textField"));

                exchange.getMessage().setBody(newBody);
            })
            .to("log:after-processing")
            // создаём новую сущность в источнике данных emodel/demo-type-2
            .to("ecos-records-mutate:?sourceId=emodel/demo-type-2");
    }

    @Override
    public void destroy() throws Exception {
        if (context != null) {
            context.close();
        }
    }
}

Пример демонстрирует следующий сценарий:

При старте приложения через @PostConstruct создаётся и запускается новый EcosCamelContext.
Роут подписывается на событие record-created по типу demo-type, извлекая нужные атрибуты записи.
В process-шаге формируется новый объект с полями, необходимыми для создания записи в целевом источнике.
Результат передаётся в endpoint ecos-records-mutate, который создаёт новую сущность в emodel/demo-type-2.
При остановке приложения контекст корректно завершается в методе destroy().

См. также

Endpoint ecos-records-mutate