Revision b1dadd0e snf-pithos-backend/pithos/backends/util.py

b/snf-pithos-backend/pithos/backends/util.py
43 43
class PithosBackendPool(ObjectPool):
44 44
    def __init__(self, size=None, db_module=None, db_connection=None,
45 45
                 block_module=None, block_path=None, block_umask=None,
46
                 queue_module=None, queue_connection=None):
46
                 queue_module=None, queue_hosts=None,
47
                 queue_exchange=None,
48
                 free_versioning=True):
47 49
        super(PithosBackendPool, self).__init__(size=size)
48 50
        self.db_module = db_module
49 51
        self.db_connection = db_connection
......
51 53
        self.block_path = block_path
52 54
        self.block_umask = block_umask
53 55
        self.queue_module = queue_module
54
        self.queue_connection = queue_connection
55

  
56
        self.queue_hosts = queue_hosts
57
        self.queue_exchange = queue_exchange
58
        self.free_versioning = free_versioning
59
    
56 60
    def _pool_create(self):
57 61
        backend = connect_backend(db_module=self.db_module,
58 62
                                  db_connection=self.db_connection,
......
60 64
                                  block_path=self.block_path,
61 65
                                  block_umask=self.block_umask,
62 66
                                  queue_module=self.queue_module,
63
                                  queue_connection=self.queue_connection)
67
                                  queue_hosts=self.queue_hosts,
68
                                  queue_exchange=self.queue_exchange,
69
                                  free_versioning=self.free_versioning)
64 70

  
65 71
        backend._real_close = backend.close
66 72
        backend.close = instancemethod(_pooled_backend_close, backend,

Also available in: Unified diff