Revision db400d82 snf-cyclades-app/synnefo/logic/dispatcher.py

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

  		





  108
  108
  
    
        # Declare queues and exchanges


  		





  109
  109
  
    
        for exchange in settings.EXCHANGES:


  		





  110
  
  
    
            self.client.exchange_declare(exchange_name=exchange,


  		





  111
  
  
    
                                         exchange_type="topic")


  		





  
  110
  
    
            self.client.exchange_declare(exchange=exchange,


  		





  
  111
  
    
                                         type="topic")


  		





  112
  112
  
    

  		





  113
  113
  
    
        for queue in QUEUES:


  		





  114
  114
  
    
            # Queues are mirrored to all RabbitMQ brokers


  		





  115
  
  
    
            self.client.queue_declare(queue=queue,mirrored=True)


  		





  
  115
  
    
            self.client.queue_declare(queue=queue, mirrored=True)


  		





  116
  116
  
    

  		





  117
  117
  
    
        bindings = BINDINGS


  		





  118
  118
  
    

  		












Also available in:
  Unified diff