#NEWLINE# def _receive( self , msg ) : #NEWLINE# #INDENT# '\n        We have a message!\n\n        Instead of the synchronous version we do not handle serializing and\n        sending the result to the `self._outsocket`. This has to be handled by\n        the `self._processing` method.\n        ' #NEWLINE# message = DataMessage ( msg ) #NEWLINE# try : #NEWLINE# #INDENT# self . _processing ( message , self . _out_stream ) #NEWLINE# #UNINDENT# except : #NEWLINE# #INDENT# self . _logger . critical ( 'Uncaught exception executing the worker!' ) #NEWLINE# self . _logger . critical ( traceback . format_exc ( ) )