Commit cc5f044c authored by Christos Stavrakakis's avatar Christos Stavrakakis
Browse files

Fix bug in puka client

parent 2bb80053
......@@ -64,7 +64,7 @@ def reconnect_decorator(func):
@wraps(func)
def wrapper(self, *args, **kwargs):
try:
func(self, *args, **kwargs)
return func(self, *args, **kwargs)
except (socket_error, spec_exceptions.ConnectionForced) as e:
logger.error('Connection Closed while in %s: %s', func.__name__, e)
self.consume_promises = []
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment