@Test
public void failsTupleWhenClientThrows() throws Exception {

    when(client.get(request)).thenThrow(ElasticsearchException.class);
    bolt.execute(tuple);
    verify(outputCollector).fail(tuple);
}