Revision fde763c3 db/db_controller.py

b/db/db_controller.py
72 72 

  		





  73
  73
  
    
def declare_queues(chan):


  		





  74
  74
  
    
    chan.exchange_declare(exchange=settings.EXCHANGE_GANETI, type="topic", durable=True, auto_delete=False)


  		





  
  75
  
    
    chan.exchange_declare(exchange=settings.EXCHANGE_CRON, type="topic", durable=True, auto_delete=False)


  		





  
  76
  
    
    chan.exchange_declare(exchange=settings.EXCHANGE_API, type="topic", durable=True, auto_delete=False)


  		





  
  77
  
    

  		





  75
  78
  
    
    chan.queue_declare(queue=settings.QUEUE_GANETI_EVENTS, durable=True, exclusive=False, auto_delete=False)


  		





  
  79
  
    
    chan.queue_declare(queue=settings.QUEUE_CRON_CREDITS, durable=True, exclusive=False, auto_delete=False)


  		





  
  80
  
    
    chan.queue_declare(queue=settings.QUEUE_API_EMAIL, durable=True, exclusive=False, auto_delete=False)


  		





  
  81
  
    
    chan.queue_declare(queue=settings.QUEUE_CRON_EMAIL, durable=True, exclusive=False, auto_delete=False)


  		





  76
  82
  
    

  		





  77
  83
  
    
def init_devel():


  		





  78
  84
  
    
    chan = open_channel()


  		












Also available in:
  Unified diff