Revision 6d27eadd snf-common/synnefo/lib/amqp_puka.py

b/snf-common/synnefo/lib/amqp_puka.py
44 44 

  		





  45
  45
  
    
from puka import Client


  		





  46
  46
  
    
from puka import spec_exceptions


  		





  
  47
  
    
import socket


  		





  47
  48
  
    
from socket import error as socket_error


  		





  48
  49
  
    
from time import sleep


  		





  49
  50
  
    
from random import shuffle


  		





  ......




  128
  129
  
    

  		





  129
  130
  
    
        logger.info('Successfully connected to host: %s', host)


  		





  130
  131
  
    

  		





  
  132
  
    
        # Setup TCP keepalive option


  		





  
  133
  
    
        self.client.sd.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)


  		





  
  134
  
    
        # Keepalive time


  		





  
  135
  
    
        self.client.sd.setsockopt(socket.SOL_TCP, socket.TCP_KEEPIDLE, 20)


  		





  
  136
  
    
        # Keepalive interval


  		





  
  137
  
    
        self.client.sd.setsockopt(socket.SOL_TCP, socket.TCP_KEEPINTVL, 2)


  		





  
  138
  
    
        # Keepalive retry


  		





  
  139
  
    
        self.client.sd.setsockopt(socket.SOL_TCP, socket.TCP_KEEPCNT, 10)


  		





  
  140
  
    

  		





  131
  141
  
    
        logger.info('Creating channel')


  		





  132
  142
  
    

  		





  133
  143
  
    
        if self.unacked:


  		












Also available in:
  Unified diff