changed distributed architecture, now does a work pull pattern based on work ids and work availability rather than topic based, this gets rid of duplicate work being done