channel.py 文件源码

def __init__(
            self,
            client_namespace="channel-clients",
            message_namespace="channel-buckets",
            channels=None,
            max_message_backlog=200,
            pull_retries=37,
            pull_sleep=1.5,
            default_cas_ttl=60*30):
        """
            Creates a channel manager
        """
        assert channels
        self.client_namespace = client_namespace
        self.message_namespace = message_namespace
        self.client = memcache.Client()
        self.default_cas_ttl = default_cas_ttl
        self.max_message_backlog = max_message_backlog
        self.channels = channels
        self.pull_retries = pull_retries
        self.pull_sleep = pull_sleep