Model "Post office" (receive-process-send) for message processing.

[KuldeepSinh]

1. Published message should be immediately stored in the Message Store.
2. Once the message is stored, it should be parsed to find out the topic.
3. Based on the topic, all the subscribers (ID and their message boxes) should be retrieved.
4. The message ID should be pushed into the queue (message box) of each subscriber.
5. The sender for each subscriber should pop the message, and send it to the subscriber over the TCP/IP.

Note : For This flow create a separate subtask.

[KuldeepSinh]

Reference : https://about.usps.com/publications/pub100/pub100_078.htm