Refactors subscribers
Minor changes to topic and fifo
Adds queues
Adds fanout service