Procesamiento de Clientes
El procesamiento de clientes es un módulo acoplable que enviará una notificación a una implementación descendente para informarle que los componentes generados por Debulker están listos para ser procesados. También maneja la recepción de notifications para informar el Debulker los componentes han sido procesados, de modo que el Debulker puede realizar operaciones de mantenimiento.
Interfaz
La interfaz Component Processing Initiation Port se define de la siguiente manera y se utiliza para enviar notifications que los componentes están listos para ser procesados.
public interface ComponentProcessingInitiationPort {
CompletionStage<Void> initiateProcessing(InitiateComponentProcessingCommand command); (1)
}| 1 | initiate Processing se utiliza para enviar Initiate Component Processing Command. |
La interfaz Component Processing Completion Port se define de la siguiente manera y manejará notifications que el procesamiento de componentes se ha completado. Una aplicación que utilice este módulo deberá implementarlo.
public interface ComponentProcessingCompletionPort {
CompletionStage<Void> processingComplete(CompleteComponentProcessingCommand command); (1)
}| 1 | processing Complete se utiliza para manejar Complete Component Processing Command. |
Implementaciones
Una biblioteca de conectores se utiliza para enviar y consumir mensajes hacia/desde una tecnología de transporte específica. Actualmente, la única implementación de transporte es Kafka pero los usuarios pueden escribir implementaciones para otras tecnologías.