@Test(timeout = 5000)
public void test_nlp_app_progress_rate__two_init_add_values() throws Exception {

    NlpApp nlpApp = runNlpApp("1", 0);
    assertThat(nlpApp.getProgressRate()).isEqualTo(-1);
    dataBus.publish(Channel.NLP, new Message(INIT_MONITORING).add(VALUE, "4"));
    dataBus.publish(Channel.NLP, new Message(INIT_MONITORING).add(VALUE, "6"));
    dataBus.publish(Channel.NLP, new Message(EXTRACT_NLP).add(DOC_ID, "doc_id").add(R_ID, "routing").add(INDEX_NAME, local().id));
    dataBus.publish(Channel.NLP, new ShutdownMessage());
    shutdownNlpApp();
    assertThat(nlpApp.getProgressRate()).isEqualTo(0.1);
}