@Test
    void testCheckArchive() throws IOException {
        setConfigValueMapper(DataStoreServiceConfig.class, config -> config
                .withDeletePurgeAge(StroomDuration.ZERO)
                .withFileSystemCleanOldAge(StroomDuration.ZERO));

        fileSystemCleanTaskExecutor.scan();

        final ZonedDateTime oldDate = ZonedDateTime.now(ZoneOffset.UTC).minusDays(SIXTY);
        final ZonedDateTime newDate = ZonedDateTime.now(ZoneOffset.UTC).minusDays(FIFTY);

        // Write a file 2 files ... on we leave locked and the other not locked
        final String feedName = FileSystemTestUtil.getUniqueTestString();
//        final DocRef feedRef = feedStore.createDocument(feedName);

        setupDataRetentionRules(feedName);

        final MetaProperties oldFile = MetaProperties.builder()
                .feedName(feedName)
                .typeName(StreamTypeNames.RAW_EVENTS)
                .createMs(oldDate.toInstant().toEpochMilli())
                .build();
        final MetaProperties newFile = MetaProperties.builder()
                .feedName(feedName)
                .typeName(StreamTypeNames.RAW_EVENTS)
                .createMs(newDate.toInstant().toEpochMilli())
                .build();

        Meta oldFileMeta;
        try (final Target oldFileTarget = streamStore.openTarget(oldFile)) {
            oldFileMeta = oldFileTarget.getMeta();
            TargetUtil.write(oldFileTarget, "MyTest");
        }

        Meta newFileMeta;
        try (final Target newFileTarget = streamStore.openTarget(newFile)) {
            newFileMeta = newFileTarget.getMeta();
            TargetUtil.write(newFileTarget, "MyTest");
        }

        List<DataVolume> oldVolumeList = dataVolumeService
                .find(FindDataVolumeCriteria.create(oldFileMeta)).getValues();
        assertThat(oldVolumeList.size()).as("Expecting 1 stream volumes").isEqualTo(REPLICATION_COUNT);

        List<DataVolume> newVolumeList = dataVolumeService
                .find(FindDataVolumeCriteria.create(newFileMeta)).getValues();
        assertThat(newVolumeList.size()).as("Expecting 1 stream volumes").isEqualTo(REPLICATION_COUNT);

        dataRetentionPolicyExecutor.exec();
        physicalDeleteExecutor.exec();

        // Test Again
        oldVolumeList = dataVolumeService.find(FindDataVolumeCriteria.create(oldFileMeta)).getValues();
        assertThat(oldVolumeList.size()).as("Expecting 0 stream volumes").isEqualTo(0);

        newVolumeList = dataVolumeService.find(FindDataVolumeCriteria.create(newFileMeta)).getValues();
        assertThat(newVolumeList.size()).as("Expecting 1 stream volumes").isEqualTo(REPLICATION_COUNT);

        // Test they are
        oldVolumeList = dataVolumeService.find(FindDataVolumeCriteria.create(oldFileMeta)).getValues();
        assertThat(oldVolumeList.size()).as("Expecting 0 stream volumes").isEqualTo(0);
        newVolumeList = dataVolumeService.find(FindDataVolumeCriteria.create(newFileMeta)).getValues();
        assertThat(newVolumeList.size()).as("Expecting 1 stream volumes").isEqualTo(REPLICATION_COUNT);
    }
Test the archiving stuff.
<p>
Create some old files and make sure they get archived.
stroom-app/src/test/java/stroom/data/store/impl/fs/TestDataRetentionPolicyExecutor.java