public void createBasicTranslateStreamProcessor(final String feed) {
        final QueryData findStreamQueryData = QueryData.builder()
                .dataSource(MetaFields.STREAM_STORE_DOC_REF)
                .expression(ExpressionOperator.builder()
                        .addTextTerm(MetaFields.FEED, ExpressionTerm.Condition.EQUALS, feed)
                        .addTextTerm(MetaFields.TYPE, ExpressionTerm.Condition.EQUALS, StreamTypeNames.RAW_EVENTS)
                        .build())
                .build();

        createProcessor(findStreamQueryData);
    }
Help class to create some basic scenarios for testing.
stroom-app/src/test/java/stroom/test/CommonTestScenarioCreator.java