@Test
public void reportsExceptionWhenClientThrows() throws Exception {

    ElasticsearchException elasticsearchException = new ElasticsearchException("dummy");
    when(client.get(request)).thenThrow(elasticsearchException);
    bolt.execute(tuple);
    verify(outputCollector).reportError(elasticsearchException);
}