Revision ec5e7c9d

b/snf-cyclades-gtools/synnefo/ganeti/progress_monitor.py
93 93 
        msg['event_time'] = split_time(time.time())
94 94 
        msg['instance'] = instance_name
95 95 

  		





  96
  
  
    
        # and send it over AMQP


  		





  
  96
  
    
        # log to stderr


  		





  
  97
  
    
        sys.stderr.write("[MONITOR] %s\n" % json.dumps(msg))


  		





  
  98
  
    

  		





  
  99
  
    
        # then send it over AMQP


  		





  97
  100
  
    
        amqp_client.basic_publish(exchange=settings.EXCHANGE_GANETI,


  		





  98
  101
  
    
                                  routing_key=routekey,


  		





  99
  102
  
    
                                  body=json.dumps(msg))


  		












Also available in:
  Unified diff