It doesn't seem to be working yet, not sure why but I think it has something to do with the instantiation of the Concurrent.broadcast