Debulker en Su Aplicación

El primer paso es agregar el Debulker módulos de inicio de maven a su IPF application pom.

Debulker Inicio

El iniciador le proporciona los módulos base para poner en funcionamiento un desmenuzador:

<!--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 del Módulo

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 del archivo que debe activar el desagregado del archivo.

  • ipf-file-manager - responsable de archivar el archivo masivo después de que haya sido procesado con éxito.

  • ipf-debulker-client-processing - notifica a un sistema externo que el desmoldeo ha finalizado y que los componentes producidos pueden ser procesados. Esto también consume la notificación de procesamiento exitoso de esos componentes por parte del sistema externo, para que pueda comenzar a realizar tareas de mantenimiento.

Añadiendo dependencias necesarias para los módulos de inicio

A continuación, se presenta un ejemplo de las dependencias o implementaciones específicas que puede agregar, en este caso utilizando MongoDB para el almacén de componentes 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>