docs: async function check(){
              if (broker.emitter.open <= 0) return true;
              else { 
                  this.logger.warn("Event queue not empty... waiting", {queue: broker.emitter.open});
                  throw "Retry";
              }
          }