def run(self):
        """ Queue manager job callback.
        """
        try:
            self.proxy = config_ini.engine.open()

            # Get items from 'pyrotorque' view
            items = list(config_ini.engine.items(self.VIEWNAME, cache=False))

            if self.sort_key:
                items.sort(key=self.sort_key)
                #self.LOG.debug("Sorted: %r" % [i.name for i in items])

            # Handle found items
            self._start(items)
            self.LOG.debug("%s - %s" % (config_ini.engine.engine_id, self.proxy))
        except (error.LoggableError, xmlrpc.ERRORS) as exc:
            # only debug, let the statistics logger do its job
            self.LOG.debug(str(exc))
Queue manager job callback.