This is an implementation of NetMQ into a proto-type messaging system for a micro-service architecture. It uses the XPub/XSub Pattern from NetMQ to allow for a dynamic and scalable messaging system.
It is comprised of 4 pieces:
- Intermediary
- This allows for publishers and subscribers to communicate without knowing anything about the other party.
- Publisher
- This pushes messages to be processed by any number of subscribers.
- Subscriber
- This listens and processes messages that are sent by publishers.
- Event Service
- This is a 'blind-broker' that subscribes to a topic, stores any received messages in a database and then periodically kicks up a queue to re-send messages.
This was made for two reasons:
1) To further my own understanding of Event Messaging.
2) To create a flexible proto-type for use on a project.