protected void deleteIndex(String name) {
int max = 5;
int count = 0;
logger.info("Delete index [{}]", name);
IndicesExistsResponse response = node.client().admin().indices().prepareExists(name).get();
if (!response.isExists()) {
logger.info("Index {} does not exist", name);
return;
}
if (!node.client().admin().indices().prepareDelete(name).execute().actionGet().isAcknowledged()) {
response = node.client().admin().indices().prepareExists(name).get();
while (response.isExists()) {
logger.debug("Index {} not deleted. Try waiting 1 sec...", name);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
}