code: def _initialize_messages_queues(self, chain_state: ChainState):
          
          assert not self.transport, f'Transport is running. node:{self!r}'
          assert self.alarm.is_primed(), f'AlarmTask not primed. node:{self!r}'
  
          events_queues = views.get_all_messagequeues(chain_state)
  
          for queue_identifier, event_queue in events_queues.items():
              self.start_health_check_for(queue_identifier.recipient)
  
              for event in event_queue:
                  message = message_from_sendevent(event)
                  self.sign(message)
                  self.transport.send_async(queue_identifier, message)
docs: Initialize all the message queues with the transport.
  
          Note:
              All messages from the state queues must be pushed to the transport
              before it's started. This is necessary to avoid a race where the
              transport processes network messages too quickly, queueing new
              messages before any of the previous messages, resulting in new
              messages being out-of-order.
  
              The Alarm task must be started before this method is called,
              otherwise queues for channel closed while the node was offline
              won't be properly cleared. It is not bad but it is suboptimal.