removed unused field
added persistent subscribers, that is a subscriber that survives a rabbitMQ crash/restart
fix: the observable returned from the Observe method did not broadcast to all subscribers