@Test
public void create_index_throws_correct_exception_when_underlying_client_throws() throws Exception {

    when(client.indices()).thenThrow(new RuntimeException());
    TestUtils.assertThrows(() -> ElasticSearchUtils.createIndex(client, ""), CreateIndexFailedException.class);
}