private void scanVolume(final FsVolume volume,
                            final Consumer<Path> orphanConsumer,
                            final Instant oldestDirTime,
                            final TaskContext taskContext) {
        final Path absDir = pathCreator.toAppPath(volume.getPath());
        if (!Files.isDirectory(absDir)) {
            LOGGER.error(() -> "Directory for file delete list does not exist '" +
                    FileUtil.getCanonicalPath(absDir) +
                    "'");
        } else {
            orphanFileFinderProvider.get().scanVolumePath(volume, orphanConsumer, oldestDirTime, taskContext);
        }
    }
Task to clean the stream store.
stroom-data/stroom-data-store-impl-fs/src/main/java/stroom/data/store/impl/fs/FsOrphanFileFinderExecutor.java