    @Test
    public void onNewConfigsFromScheduler_shouldStartContainerLogfileFileStreamingWithCorrectDockerFramework() {

        List<LogstashConfig> dockerFrameworks = asLogstashConfigList(framework1, framework2,
            framework3);
        List<LogstashConfig> hostFrameworks = asLogstashConfigList(hostFramework);

        configureAsRunningFrameworks(framework1);

        configManager.onNewConfigsFromScheduler(hostFrameworks, dockerFrameworks);

        verify(streamManager, times(1)).setupContainerLogfileStreaming(
            dockerFrameworkArgumentCaptor.capture());

        DockerFramework expectedDockerFramework = new DockerFramework(framework1.getLogstashConfig(),
            new DockerFramework.ContainerId(framework1.getId()));

        assertEquals(expectedDockerFramework.getContainerId(),
            dockerFrameworkArgumentCaptor.getAllValues().get(0).getContainerId());
        assertEquals(expectedDockerFramework.getConfiguration(),
            dockerFrameworkArgumentCaptor.getAllValues().get(0).getConfiguration());
        assertEquals(expectedDockerFramework.getName(),
            dockerFrameworkArgumentCaptor.getAllValues().get(0).getName());
    }