MQTT Broker is my project for Distributed Systems course at the University of Catania. It is simple but quite functional. Broker is based on Akka Runtime, the reason for using actor model is that it makes implementing asynchronous applications easy and intuitive, Sequence Diagram for message processing flow as well as other illustrations can be seen here:
The overall architecture of the broker is illustrated as follows:
