@Test(expected = ExecutionException.class)
public void testAddFailure() throws Exception {

  SettableApiFuture<Void> future = SettableApiFuture.create();
  when(batcher.add(rowMutation)).thenReturn(future);
  future.setException(new RuntimeException("can not perform mutation"));
  ApiFuture<Void> result = bulkMutationClient.add(rowMutation);
  assertTrue(result.isDone());
  verify(batcher).add(rowMutation);
  result.get();
}