@Test
    void testFeedChange() {
        streamStore.clear();

        final String feedName1 = FileSystemTestUtil.getUniqueTestString();
        final AttributeMap attributeMap1 = new AttributeMap();
        attributeMap1.put(StandardHeaderArguments.FEED, feedName1);
        attributeMap1.put(StandardHeaderArguments.TYPE, StreamTypeNames.RAW_EVENTS);

        final String feedName2 = FileSystemTestUtil.getUniqueTestString();
        final AttributeMap attributeMap2 = new AttributeMap();
        attributeMap2.put(StandardHeaderArguments.FEED, feedName2);
        attributeMap2.put(StandardHeaderArguments.TYPE, StreamTypeNames.RAW_EVENTS);

        final ProgressHandler progressHandler = new ProgressHandler("Test");
        final StreamTargetStreamHandlers streamTargetStreamHandlers = new StreamTargetStreamHandlers(
                streamStore,
                feedProperties,
                metaService,
                null,
                volumeGroupNameProvider);
        streamTargetStreamHandlers.handle(feedName1, StreamTypeNames.RAW_EVENTS, attributeMap1, handler -> {
            try {
                handler.addEntry("1" + StroomZipFileType.META.getDotExtension(),
                        new ByteArrayInputStream(new byte[0]), progressHandler);
                handler.addEntry("1" + StroomZipFileType.CONTEXT.getDotExtension(),
                        new ByteArrayInputStream(new byte[0]), progressHandler);
                handler.addEntry("1" + StroomZipFileType.DATA.getDotExtension(),
                        new ByteArrayInputStream(new byte[0]), progressHandler);
            } catch (final IOException e) {
                throw new UncheckedIOException(e);
            }
        });

        streamTargetStreamHandlers.handle(feedName2, StreamTypeNames.RAW_EVENTS, attributeMap2, handler -> {
            try {
                handler.addEntry("2" + StroomZipFileType.META.getDotExtension(),
                        new ByteArrayInputStream(new byte[0]), progressHandler);
                handler.addEntry("2" + StroomZipFileType.CONTEXT.getDotExtension(),
                        new ByteArrayInputStream(new byte[0]), progressHandler);
                handler.addEntry("2" + StroomZipFileType.DATA.getDotExtension(),
                        new ByteArrayInputStream(new byte[0]), progressHandler);
            } catch (final IOException e) {
                throw new UncheckedIOException(e);
            }
        });

        assertThat(streamStore.getStreamStoreCount()).isEqualTo(2);
    }
This test is used to check that separate streams are created if the feed
changes.

@throws IOException
stroom-app/src/test/java/stroom/receive/TestStreamTargetStreamHandler.java