Agent-to-Nodes streams

Agent to Nodes communication through PubSub stream
and Nodes to Agent through PushPull socket.
Queue between Agent threads