Revision e0b68525

b/snf-common/synnefo/lib/amqp_puka.py
64 64 
    @wraps(func)
65 65 
    def wrapper(self, *args, **kwargs):
66 66 
        try:
67 
            func(self, *args, **kwargs)
67 
            return func(self, *args, **kwargs)
68 68 
        except (socket_error, spec_exceptions.ConnectionForced) as e:
69 69 
            logger.error('Connection Closed while in %s: %s', func.__name__, e)
70 70 
            self.consume_promises = []

Also available in: Unified diff