def _message_any self msg self _logger debug Incoming message user sel

    def _message_any(self, msg):
        self._logger.debug("Incoming message...")
        user = self.registry.get(jid_to_dbkey(msg.get_from()))
        if user is None:
            self.stream.send(msg.make_error_response('forbidden'))
            return True
        ...