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.