Refactor the project
Redesign the system. The messagebus layer has Master and NodeContainer
classes. NodeContainer contains both sink and source fucntionality. 
Refactor the method for prepRcvData() and sendData() so the fucntional
node spawns threads instead of NodeContainer.