@Test
public void testDoExtractResponse() throws Exception {

    final String message = "this is a test";
    BasicHttpEntity entity = new BasicHttpEntity();
    try(ByteArrayInputStream bis = new ByteArrayInputStream(message.getBytes())) {
        entity.setContent(bis);
    }
    catch (IOException e) {
        throw e;
    }
    String responseMessage = ElasticSearchQueryStoreService.doExtractResponse(200, entity);
    assertEquals("expect the entity to be equal after extraction", message, responseMessage);
}