code: def reconnect(self):
          
          try:
              self.conn.close()
          except Exception,e:
              self.logger.warn(e)
  
          self.createConnection()
  
          return True
docs: Allows reconnection from when a handled
          TransportException is thrown