code: def manage_brok(self, brok):
          
          # Unserialize the brok before consuming it
          brok.prepare()
  
          for module in self.modules_manager.get_internal_instances():
              try:
                  _t0 = time.time()
                  module.manage_brok(brok)
                  statsmgr.timer('manage-broks.internal.%s' % module.get_name(), time.time() - _t0)
              except Exception as exp:  # pylint: disable=broad-except
                  logger.warning("The module %s raised an exception: %s, "
                                 "I'm tagging it to restart later", module.get_name(), str(exp))
                  logger.exception(exp)
                  self.modules_manager.set_to_restart(module)
docs: Get a brok.
          We put brok data to the modules
  
          :param brok: object with data
          :type brok: object
          :return: None