def oplog_thread_join(self):
        """Stops all the OplogThreads
        """
        LOG.info("MongoConnector: Stopping all OplogThreads")
        for thread in self.shard_set.values():
            thread.join()