TRANG 4: Trục Tin nhắn RabbitMQ & Kafka (Messaging Layer)

4.1. Hệ thống RabbitMQ (Reliable Messaging) 

 Được cấu hình thông qua  MessageStore  và  MessageProcessor : 

 

 Message Store:   EDXMLMessageStore  kết nối trực tiếp tới Queue trên RabbitMQ. 

 Message Processor:   SendEdoc2  đóng vai trò là "Worker" thức dậy định kỳ để đẩy tin nhắn đi. 

 Cơ chế Retry:  Nếu hệ thống đích (NGSP/Bộ ngành) lỗi 503, tin nhắn sẽ quay lại Queue và thử lại sau N giây. 

 

 4.2. Hệ thống Kafka (Event Streaming) 

 Sử dụng  KafkaProducerAPI  để đẩy các sự kiện dữ liệu lớn: 

 

 Đẩy dữ liệu nhật ký hội thoại hoặc log hệ thống. 

 Cung cấp dữ liệu cho hệ thống giám sát thời gian thực của tỉnh.