code: def consume(self, msg):
          
          log.debug("Got message %r" % msg)
          topic, body = msg.get('topic'), msg.get('body')
  
          for client in self.irc_clients:
              if not client.factory.filters or (
                  client.factory.filters and
                  self.apply_filters(client.factory.filters, topic, body)
              ):
                  raw_msg = self.prettify(
                      topic=topic,
                      msg=body,
                      pretty=client.factory.pretty,
                      terse=client.factory.terse,
                      short=client.factory.short,
                  )
                  send = getattr(client, self.hub.config['irc_method'], 'notice')
                  send(client.factory.channel, raw_msg.encode('utf-8'))
  
                  backlog = self.incoming.qsize()
                  if backlog and (backlog % 20) == 0:
                      warning = "* backlogged by %i messages" % backlog
                      log.warning(warning)
                      send(client.factory.channel, warning.encode('utf-8'))
docs: Forward on messages from the bus to all IRC connections.