dispatcher.py 文件源码

def on_message_received(self, namespace, message):
        consumers = self.consumers.get(namespace, [])

        # Compress the message
        if len(message) >= MIN_COMPRESS_SIZE:
            compressed = make_compressed_frame(message, COMPRESSOR)
        else:
            compressed = None
        message = Message(compressed=compressed, raw=message)

        with self.metrics.timer("dispatch"):
            for consumer in consumers:
                consumer.put(message)