Elasticsearch determine new index

gistfile1.txt

private int findCurrentIndex(String aliasName, int indexCount)
{
	Map<String, AliasOrIndex> allAliases = elasticClient
		.admin()
		.cluster()
		.state(Requests.clusterStateRequest())
		.actionGet()
		.getState()
		.getMetaData()
		.getAliasAndIndexLookup();
	
	AliasOrIndex alias = allAliases.get(aliasName);
	
	if(alias != null)
	{
		if(!alias.isAlias())
		{
			throw new IllegalStateException(String.format("Concrete index with alias name (%s) already exists. Aborting.", aliasName));
		}
		if(alias.getIndices().size() > 1)
		{
			throw new IllegalStateException("Alias has multiple records. Aborting.");
		}
		else
		{
			return getIndexId(alias.getIndices().get(0).getIndex());
		}
	}
	
	return -1;
}

private String buildIndexName(String aliasName, int id)
{
	return String.format("%s-%d", aliasName, id);
}

private int getIndexId(String indexName)
{
	String[] parts = indexName.split("-");
	return Integer.valueOf(parts[parts.length - 1]);
}