Revision 370f69ec snf-cyclades-app/synnefo/logic/dispatcher.py

b/snf-cyclades-app/synnefo/logic/dispatcher.py
78 78 

  		





  79
  79
  
    
class Dispatcher:


  		





  80
  80
  
    
    debug = False


  		





  81
  
  
    
    client_promises = []


  		





  82
  81
  
    

  		





  83
  82
  
    
    def __init__(self, debug=False):


  		





  84
  83
  
    
        self.debug = debug


  		





  ......




  127
  126
  
    
            self.client.queue_bind(queue=binding[0], exchange=binding[1],


  		





  128
  127
  
    
                                   routing_key=binding[2])


  		





  129
  128
  
    

  		





  130
  
  
    
            consume_promise = self.client.basic_consume(queue=binding[0],


  		





  
  129
  
    
            self.client.basic_consume(queue=binding[0],


  		





  131
  130
  
    
                                                        callback=callback)


  		





  132
  131
  
    

  		





  133
  132
  
    
            log.debug("Binding %s(%s) to queue %s with handler %s",


  		





  134
  133
  
    
                      binding[1], binding[2], binding[0], binding[3])


  		





  135
  
  
    
            self.client_promises.append(consume_promise)


  		





  136
  134
  
    

  		





  137
  135
  
    

  		





  138
  136
  
    
def _init_queues():


  		












Also available in:
  Unified diff