Replicator

  @Inject
  public Replicator(IndicesService service, Client client, MessageProducer producer){
		this.indicesService = service;
		this.client = client;
    setupIndex();
		registerListener();
	}
  
  private void setupIndex() {
  	try {
			if(!client.admin().indices().exists(new IndicesExistsRequest(ReplicationModule.REPLICATION_INDEX)).actionGet().isExists()){
				client.admin().indices().create(new CreateIndexRequest(ReplicationModule.REPLICATION_INDEX));
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		
	}