'Process PDUs which got queued up while we were busy send_joining.
Args:
room_queue (list[FrozenEvent, str]): list of PDUs to be processed
and the servers that sent them'

@defer.inlineCallbacks
def _handle_queued_pdus(self, room_queue):

    for (p, origin) in room_queue:
        try:
            logger.info('Processing    queued    PDU    %s    which    was    received    while    we    were    joining    %s', p.event_id, p.room_id)
            (yield self.on_receive_pdu(origin, p))
        except Exception as e:
            logger.warn('Error    handling    queued    PDU    %s    from    %s:    %s', p.event_id, origin, e)
