def process(self):
subscription = None<EOL>result = None<EOL>try:<EOL><INDENT>subscription = self.socket.recv()<EOL><DEDENT>except AuthenticateError as exception:<EOL><INDENT>logging.error(<EOL>'<STR_LIT>'<EOL>.format(exception), exc_info=<NUM_LIT:1>)<EOL><DEDENT>except AuthenticatorInvalidSignature as exception:<EOL><INDENT>logging.error(<EOL>'<STR_LIT>'<EOL>.format(exception), exc_info=<NUM_LIT:1>)<EOL><DEDENT>except DecodeError as exception:<EOL><INDENT>logging.error(<EOL>'<STR_LIT>'<EOL>.format(exception), exc_info=<NUM_LIT:1>)<EOL><DEDENT>except RequestParseError as exception:<EOL><INDENT>logging.error(<EOL>'<STR_LIT>'<EOL>.format(exception), exc_info=<NUM_LIT:1>)<EOL><DEDENT>else:<EOL><INDENT>logging.debug(<EOL>'<STR_LIT>'<EOL>.format(subscription))<EOL><DEDENT>_tag, message, fun = self.parse(subscription)<EOL>message = self.verify(message)<EOL>message = self.decode(message)<EOL>try:<EOL><INDENT>result = fun(message)<EOL><DEDENT>except Exception as exception:<EOL><INDENT>logging.error(exception, exc_info=<NUM_LIT:1>)<EOL><DEDENT>return result<EOL>
Receive a subscription from the socket and process it