'Shutdown the indexer.
This must be done even if the the indexer thread was never
.start()\'ed -- because of the thread used for the
_StagingRequestQueue.'

def finalize(self):

    self._stopping = True
    if isinstance(self._requests, _StagingRequestQueue):
        self._requests.finalize()
    if self.isAlive():
        self.add_request(IndexerStopRequest())
        try:
            self.join(5)
        except AssertionError:
            pass
