class PurgeFiltersJob implements Runnable {

    @Override
    public void run() {
        try {
            purgatory.purge();
        } catch (Exception ex) {
            logger.error("Purge bloom filter service failed.", ex);
        }
    }

      PurgeFiltersJob(Purgatory purgatory);

}