code: def _initial_broks(self, broker_name):
          
          with self.app.conf_lock:
              logger.info("A new broker just connected : %s", broker_name)
              return self.app.sched.fill_initial_broks(broker_name)
docs: Get initial_broks from the scheduler
  
          This is used by the brokers to prepare the initial status broks
  
          This do not send broks, it only makes scheduler internal processing. Then the broker
          must use the *_broks* API to get all the stuff
  
          :param broker_name: broker name, used to filter broks
          :type broker_name: str
          :return: None