code: async def run(self):
          
          logging.info('Starting message router...')
  
          coroutines = set()
          while True:
              coro = self._poll_channel()
              coroutines.add(coro)
              _, coroutines = await asyncio.wait(coroutines, timeout=0.1)
docs: Entrypoint to route messages between plugins.