@Test
    void test() throws IOException {
        setup(FEED_NAME, RESOURCE_NAME);
        assertThat(metaService.getLockCount()).isEqualTo(0);

        final List<ProcessorResult> results = commonTranslationTestHelper.processAll();
        assertThat(results.size()).isEqualTo(1);

        for (final ProcessorResult result : results) {
            final String message = "Count = " + result.getRead() + "," + result.getWritten() + ","
                    + result.getMarkerCount(Severity.SEVERITIES);

            assertThat(result.getWritten() > 0).as(message).isTrue();
            assertThat(result.getRead() <= result.getWritten()).as(message).isTrue();
            assertThat(result.getMarkerCount(Severity.SEVERITIES)).as(message).isEqualTo(0);
        }

        final Path inputDir = StroomPipelineTestFileUtil.getTestResourcesDir().resolve(DIR);
        final Path outputDir = StroomPipelineTestFileUtil.getTestOutputDir().resolve(DIR);

        for (final Entry<Long, Meta> entry : metaService.getMetaMap().entrySet()) {
            final long streamId = entry.getKey();
            final Meta meta = entry.getValue();
            if (StreamTypeNames.EVENTS.equals(meta.getTypeName())) {
                final byte[] data = streamStore.getFileData().get(streamId).get(meta.getTypeName());

                // Write the actual XML out.
                final OutputStream os = StroomPipelineTestFileUtil.getOutputStream(outputDir, "TestTask.out");
                os.write(data);
                os.flush();
                os.close();

                ComparisonHelper.compareDirs(inputDir, outputDir);
            }
        }

        // Make sure 10 records were written.
        assertThat(results.get(0).getWritten()).isEqualTo(10);
    }
Tests Task with a valid resource and feed.

@throws IOException Could be thrown.
stroom-app/src/test/java/stroom/pipeline/task/TestTranslationTaskWithoutTranslation.java