Debulker en tu aplicación
El primer paso es añadir los módulos maven del Debulker starter al pom de tu aplicación IPF.
Debulker Starter
El starter te ofrece los módulos base para poner en marcha un debulker:
<!--Responsible for debulking-->
<dependency>
<groupId>com.iconsolutions.ipf.debulk</groupId>
<artifactId>ipf-debulker-starter</artifactId>
</dependency>
<!--Responsible for cleaning up after bulk components are processed by interested party-->
<dependency>
<groupId>com.iconsolutions.ipf.debulk</groupId>
<artifactId>ipf-debulker-housekeeping-starter</artifactId>
</dependency>Dependencias de módulos
Este módulo depende de algunos módulos adicionales:
-
component-store- responsable de almacenar los componentes producidos por el debulker. -
ipf-debulker-new-file-notification- responsable de consumir la notificación de archivo que debe desencadenar el debulking del archivo. -
ipf-file-manager- responsable de archivar el archivo agrupado después de que se haya procesado correctamente. -
ipf-debulker-client-processing- notifica a un sistema externo que el debulking ha finalizado y que los componentes producidos pueden procesarse. Esto también consume la notificación del procesamiento exitoso de esos componentes por el sistema externo, para que pueda comenzar a realizar housekeeping.
Añadir dependencias necesarias para los módulos starter
A continuación se muestra un ejemplo de las dependencias o implementaciones específicas que puedes añadir; en este caso se usa MongoDB para el Component Store y Kafka para notificaciones y conectores.
<!-- ipf-component-store implementation which uses mongodb to store and read components -->
<dependency>
<groupId>com.iconsolutions.ipf.componentstore</groupId>
<artifactId>ipf-component-store-mongo</artifactId>
</dependency>
<!-- Kafka receive connector implementation of ipf-debulker-new-file-notification which consumes FileNotification message which tells debulker to process bulk file -->
<dependency>
<groupId>com.iconsolutions.ipf.debulk</groupId>
<artifactId>ipf-debulker-new-file-notification-connector-kafka</artifactId>
</dependency>
<!-- ipf-debulker-archiver implementation which archives processed bulk file to local file system -->
<dependency>
<groupId>com.iconsolutions.ipf.filemanager</groupId>
<artifactId>ipf-file-manager-local</artifactId>
</dependency>
<!-- Kafka connector implementation of ipf-debulker-client-processing -->
<dependency>
<groupId>com.iconsolutions.ipf.debulk</groupId>
<artifactId>ipf-debulker-client-processing-connector-kafka</artifactId>
</dependency>