Processing Data Manejador
Todo comienza con el Processing Data Manejador, que simplemente actúa como un proxy alrededor de los actores Resequencer. Esta clase implementa un IPF Processing Data Manejador, que permite consumir instancias de Data Envelope.
El Servicio de Notificación receive connectors presenta las siguientes configuraciones:
| Clave de configuración | Descripción | Valor predeterminado |
|---|---|---|
|
El tema sobre el cual varios servicios están publicando sus eventos de datos de procesamiento de IPF. |
|
|
docs.confluent.io/platform/current/installation/configuration/consumer-configs.html Kafka ajustes del consumidor] para el tema de respuesta consumidor, como:
|
(Kafka defaults) |
Los cuales son anulados en ipf-impl.conf:
ipf.processing-data.ingress.kafka.consumer {
kafka-clients = {
group.id = ipf-notification-service-ingress-consumer-group
auto.offset.reset = earliest
}
}Vale la pena entender lo que sucede cuando el Data Envelope llega el Processing Data Manejador. El siguiente diagrama muestra esto.
Cuando el Data Envelope llega el Processing Data El controlador se pasa al actor Resequencer correspondiente para "reordenar", y luego se extraen todos los objetos del contenedor de objetos.
Pueden ser de tres tipos:
-
Contenedor de objetos MDS: se manejan por MDS Manejador de Objetos
-
Contenedor de Objetos Personalizados: son gestionados por el Manejador de Objetos Personalizados.
-
Process Object Contenedor: se manejan por Process Object Manejador
Todo MDS los objetos se procesan primero desde el sobre de datos pasado, antes de que se pasen los objetos de proceso a Process Object Manejador.
MDS Manejador de Objetos
MDSEl Manejador de Objetos instancia un servicio de caché de datos de pago. Luego, filtra mensajes de los siguientes tipos de objeto:
-
PAIN_001
-
INSTRUCCIÓN_DE_PAGO_001
-
PAIN_001_CREDIT_TRANSFER_TRANSACTION
Luego llama al servicio de caché.
Manejador de Objetos Personalizados
El Manejador de Objetos Personalizados instancia un servicio de caché de datos personalizado. Luego llama al servicio de caché.
Manejador de Objetos Pds
El manejador de objetos Pds instancia un servicio de caché de datos pds. Luego llama al servicio de caché.
Process Object Manejador
Process ObjectEl controlador instancia un Consulta de Configuración de Notificación de Estado de Pago y un Remitente de Notificaciones. Luego filtra mensajes del siguiente tipo de objeto:
-
PROCESO_FLUJO_EVENTO
Como puede ver en el diagrama, hay dos nuevos conceptos que se introdujeron:Consulta de Configuración de Notificación de Estado de Pago y Remitente de Notificaciones. Se introducen y explican en detalle en esas secciones.