@Test
public void test_get_queue_name_scan_index() {

    PipelineHelper pipelineHelper = new PipelineHelper(new PropertiesProvider(new HashMap<String, String>() {{
        put("stages", "SCAN,INDEX");
        put("queueName", "extract:queue");
    }}));
    assertThat(pipelineHelper.getQueueNameFor(DatashareCli.Stage.SCAN)).isEqualTo("extract:queue");
    assertThat(pipelineHelper.getQueueNameFor(DatashareCli.Stage.INDEX)).isEqualTo("extract:queue");
}