Revision 40360576 snf-cyclades-gtools/synnefo/ganeti/progress_monitor.py

b/snf-cyclades-gtools/synnefo/ganeti/progress_monitor.py
85 85 
    # determine the routekey for AMPQ
86 86 
    prefix = instance_name.split('-')[0]
87 87 
    routekey = "ganeti.%s.event.progress" % prefix
88 
    amqp_client = AMQPClient()
89 
    amqp_client.connect(hosts=settings.AMQP_HOSTS, confirm_buffer=10)
88 
    amqp_client = AMQPClient(confirm_buffer=10)
89 
    amqp_client.connect()
90 90 
    amqp_client.exchange_declare(settings.EXCHANGE_GANETI, "topic")
91 91 

  		





  92
  92
  
    
    for msg in jsonstream(sys.stdin):


  		












Also available in:
  Unified diff