Cómo configurar un Process Flow Solicitud para la Salida de Datos

Egresar todos los datos

Para configurar un process flow La solicitud para la salida de TODOS los datos sigue estos pasos.

Elija un pom inicial, lo que también requiere que elija un transporte, y añada la dependencia en el ipf application para el cual desea publicar ipf processing data.

El journal processor solo procesos MPS events(de tipo com.iconsolutions.ipf.core.shared.domain.event. Event) ignorará otros events y registre un mensaje de depuración con el tipo de clase en tales casos.

Para kafka elija uno de los procesos de revisión de revistas:

<dependency>
    <groupId>com.iconsolutions.ipf.core.processingdata</groupId>
    <artifactId>ipf-processing-data-egress-starter-with-journal-processor-kafka</artifactId>
</dependency>

o event reenvío:

<dependency>
    <groupId>com.iconsolutions.ipf.core.processingdata</groupId>
    <artifactId>ipf-processing-data-egress-starter-with-event-forwarder-kafka</artifactId>
</dependency>

De manera similar para http elija un procesamiento de revista:

<dependency>
    <groupId>com.iconsolutions.ipf.core.processingdata</groupId>
    <artifactId>ipf-processing-data-egress-starter-with-journal-processor-http</artifactId>
</dependency>

o event reenvío:

<dependency>
    <groupId>com.iconsolutions.ipf.core.processingdata</groupId>
    <artifactId>ipf-processing-data-egress-starter-with-event-forwarder-http</artifactId>
</dependency>

Datos Específicos de Egreso

Para configurar un process flow La solicitud para la salida de datos específicos sigue estos pasos:

Si su aplicación no necesita publicar todo processing data tipos, puede agregar complementos específicos, con una implementación de transporte específica. por ejemplo, si desea publicar system events to kafka, usted necesitaría tanto el kafka dependencia del transporte, y el sistema-event-procesador.
<dependency>
    <groupId>com.iconsolutions.ipf.core.processingdata</groupId>
    <artifactId>ipf-processing-data-egress-kafka</artifactId>
</dependency>
<dependency>
    <groupId>com.iconsolutions.ipf.core.processingdata</groupId>
    <artifactId>ipf-processing-data-egress-system-event-processor</artifactId>
</dependency>