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

b/snf-cyclades-gtools/synnefo/ganeti/progress_monitor.py
69 69 
            yield msg
70 70 
            buf = buf[idx:].strip()
71 71 

  		





  
  72
  
    

  		





  72
  73
  
    
def main():


  		





  73
  74
  
    

  		





  74
  75
  
    
    usage = "Usage: %s <instance_name>\n" % PROGNAME


  		





  ......




  84
  85
  
    
    # determine the routekey for AMPQ


  		





  85
  86
  
    
    prefix = instance_name.split('-')[0]


  		





  86
  87
  
    
    routekey = "ganeti.%s.event.progress" % prefix


  		





  87
  
  
    
    amqp_client = AMQPClient(hosts=settings.AMQP_HOSTS, confirm_buffer=2)


  		





  88
  
  
    
    amqp_client.connect()


  		





  89
  
  
    
    amqp_client.exchange_declare(settings.EXCHANGE_GANETI, type='topic')


  		





  
  88
  
    
    amqp_client = AMQPClient()


  		





  
  89
  
    
    amqp_client.connect(hosts=settings.AMQP_HOSTS, confirm_buffer=10)


  		





  
  90
  
    
    amqp_client.exchange_declare(settings.EXCHANGE_GANETI, "topic")


  		





  90
  91
  
    

  		





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


  		





  92
  93
  
    
        msg['event_time'] = split_time(time.time())


  		












Also available in:
  Unified diff