Revision c99fe4c7 db/DBController.py

b/db/DBController.py
10 10 

  		





  11
  11
  
    
from db.models import *


  		





  12
  12
  
    

  		





  
  13
  
    
#GANETI_ZMQ_PUBLISHER = "tcp://ganeti-master:5801"


  		





  
  14
  
    

  		





  
  15
  
    
def init_publisher(context):


  		





  
  16
  
    
    request = context.socket(zmq.REQ)


  		





  
  17
  
    
    request.connect('tcp://127.0.0.1:6666')


  		





  
  18
  
    
    request.send('hello')


  		





  
  19
  
    
    


  		





  
  20
  
    
    message = request.recv()


  		





  
  21
  
    

  		





  13
  22
  
    
def main():


  		





  14
  23
  
    
    context = zmq.Context()


  		





  15
  24
  
    
    


  		





  ......




  20
  29
  
    
    subscriber.setsockopt(zmq.IDENTITY, "DBController")


  		





  21
  30
  
    
    subscriber.setsockopt(zmq.SUBSCRIBE, '')


  		





  22
  31
  
    
    


  		





  
  32
  
    
    init_publisher(context)


  		





  
  33
  
    
    


  		





  23
  34
  
    
    while True:


  		





  24
  35
  
    
        message = sock.recv()


  		





  25
  36
  
    
        


  		












Also available in:
  Unified diff