def onMessage(self, msg, binary):
#        print('WebSocket: Received new message from client. '
#              '(binary={0})'.format(binary))

        try:
            self._assembler.processMessage(msg, binary)
        except InvalidRequest as e:
            self.sendErrorMessage('Invalid Request: {0}'.format(e))
        except DeadConnection:
            self.sendErrorMessage('Dead Connection')
            self.dropConnection()
        except:
            import traceback
            traceback.print_exc()
            self.sendErrorMessage('Fatal Error')
Method is called by the Autobahn engine when a message has been
dataset/ETHPy150Open rapyuta/rce/rce-comm/rce/comm/server.py/RobotWebSocketProtocol.onMessage