@Test
public void test_on_message_do_not_processNLP__when_init_fails() throws Exception {

    when(pipeline.initialize(any())).thenReturn(false);
    when(indexer.get(anyString(), anyString(), anyString())).thenReturn(createDoc("content").build());
    nlpListener.findNamedEntities("projectName","id", "routing");
    verify(pipeline, never()).process(any());
}