Client Processing
Client Processing es un módulo acoplable que enviará una notificación a una implementación downstream para informarle que los componentes generados por el Debulker están listos para ser procesados. También gestiona la recepción de notificaciones para informar al Debulker de que los componentes han sido procesados, de modo que el Debulker pueda realizar operaciones de housekeeping.
Interface
La interfaz ComponentProcessingInitiationPort se define de la siguiente manera y se utiliza para enviar notificaciones de que los componentes están listos para procesarse.
public interface ComponentProcessingInitiationPort {
CompletionStage<Void> initiateProcessing(InitiateComponentProcessingCommand command); (1)
}| 1 | initiateProcessing se usa para enviar InitiateComponentProcessingCommand. |
La interfaz ComponentProcessingCompletionPort se define de la siguiente manera y gestionará las notificaciones de que el procesamiento de componentes se ha completado. Una aplicación que use este módulo deberá implementarla.
public interface ComponentProcessingCompletionPort {
CompletionStage<Void> processingComplete(CompleteComponentProcessingCommand command); (1)
}| 1 | processingComplete se usa para gestionar CompleteComponentProcessingCommand. |
Implementations
Se utiliza una biblioteca de conectores 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.