Only start consumer and worker once publishers has published all messages