Added Listener class for easy demultiplexing pub->sub messages.
Preferably used to forward broadcast messages to worker threads.