Debulker en Su Aplicación

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

Debulker Inicio

El iniciador le proporciona los módulos base para obtener un debulker en funcionamiento:

<!--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 debulker.

  • ipf-debulker-new-file-notification - responsable de consumir la notificación del archivo que debería activar debulking del archivo.

  • ipf-file-manager - responsable de archivar el bulk archivo después de que fue procesado con éxito.

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

Añadiendo dependencias necesarias para los módulos iniciales

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