elasticsearch IT save wait

Question

i want to do an integration test using elasticsearch, while trying to do the test to see if the object was successfully saved and deleted i noticed that ES didnt instantly index the document, but had to wait a little bit (like 1 sec), is there a way to tell my save method to index istantly?

here is my test:

@Test
public void SurveySaveDelete(){
    Object lock = new Object();
    synchronized (lock) {
        Survey survey = new Survey();
        survey.setEvaluated("evaluated");
        survey.setEvaluator("evaluator");
        survey.setTimestamp("2017-1-30");
        Survey returnedSaveSurvey = new Survey();
        Survey foundSurvey = new Survey();
        returnedSaveSurvey = elasticsearchSurveyRepository.saveSurvey(survey);

        try {
            lock.wait(1500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        foundSurvey = elasticsearchSurveyRepository.findSurvey("evaluator", "evaluated", "2017-1-30");
        assertEquals("evaluated", foundSurvey.getEvaluated());
        assertEquals("evaluator", foundSurvey.getEvaluator());
        assertEquals("2017-1-30", foundSurvey.getTimestamp());

        assertEquals("evaluated", returnedSaveSurvey.getEvaluated());
        assertEquals("evaluator", returnedSaveSurvey.getEvaluator());
        assertEquals("2017-1-30", returnedSaveSurvey.getTimestamp());
        boolean wasDeleted;
        wasDeleted = elasticsearchSurveyRepository.deleteSurvey("evaluator", "evaluated", "2017-1-30");
        assertEquals(true, wasDeleted);
    }
}

as you can see i used a lock object to make my test wait for a bit, but I'm unsure if there is another way to do that (i'm learning how to code be patient with me please xD)

and here is my method to save:

 @Override
public Survey saveSurvey(Survey survey) {
    Index index = new Index.Builder(survey).index(surveyIndexName).type(surveyTypeName).build();
    try {
        client.execute(index);
        return survey;
    } catch (IOException e) {
        e.printStackTrace();
        throw new RuntimeException(e);
    }
}

chengpohi · Accepted Answer · 2017-03-01 02:59:50Z

2

client.admin().indices().prepareRefresh(indices).execute().get()

You can force refresh by RefreshRequestBuilder

answered Mar 1, 2017 at 2:59

chengpohi

14.2k1 gold badge28 silver badges43 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

paqash · Accepted Answer · 2017-02-28 23:53:40Z

0

You can refresh you index manually after you insert.

https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-refresh.html

answered Feb 28, 2017 at 23:53

paqash

2,3141 gold badge20 silver badges22 bronze badges

1 Comment

Fernando Castilla Ospina Over a year ago

ohh nice, this is what i was looking for, but how do i do it in java?

Collectives™ on Stack Overflow

elasticsearch IT save wait

2 Answers 2

Comments

1 Comment

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

Comments

1 Comment

Your Answer

Sign up or log in

Post as a guest

Related