Publisher-Subscriber Bus with N producers and M consumers. Each consumer within thread and its own queue