

def __init__(self, url='amqp://guest:guest@localhost:5672//', channel='socketio', write_only=False):
    if (kombu is None):
        raise RuntimeError('Kombu package is not installed (Run "pip install kombu" in your virtualenv).')
    super(KombuManager, self).__init__(channel=channel)
    self.url = url
    self.writer_conn = kombu.Connection(self.url)
    self.writer_queue = self._queue(self.writer_conn)

dataset/ETHPy150Open miguelgrinberg/python-socketio/socketio/kombu_manager.py KombuManager.__init__/original