@Test void testCloseThrowsException() throws Exception { doThrow(new ElasticsearchException("exception")).when(client).close(); clientFacade.close(); verify(mockAppender).doAppend(matcher(ERROR, "Error closing Elasticsearch client")); }
@Override public void close() { try { client.close(); } catch (ElasticsearchException e) { LOG.error("Error closing Elasticsearch client", e); } }
ClientFacade implements Closeable { @Override public void close() { try { client.close(); } catch (ElasticsearchException e) { LOG.error("Error closing Elasticsearch client", e); } } }
ClientFacade implements Closeable { @Override public void close() { try { client.close(); } catch (ElasticsearchException e) { LOG.error("Error closing Elasticsearch client", e); } } ClientFacade(Client client); }
ClientFacade implements Closeable { @Override public void close() { try { client.close(); } catch (ElasticsearchException e) { LOG.error("Error closing Elasticsearch client", e); } } ClientFacade(Client client); void createIndex(Index index, IndexSettings indexSettings, Stream<Mapping> mappingStream); boolean indexesExist(Index index); void deleteIndex(Index index); void refreshIndexes(); long getCount(Index index); long getCount(QueryBuilder query, Index index); SearchHits search(QueryBuilder query, int from, int size, List<Index> indexes); SearchHits search(QueryBuilder query, int from, int size, Sort sort, Index index); Aggregations aggregate(
      List<AggregationBuilder> aggregations, QueryBuilder query, Index index); Explanation explain(SearchHit searchHit, QueryBuilder query); void index(Index index, Document document); void deleteById(Index index, Document document); void processDocumentActions(Stream<DocumentAction> documentActions); @Override void close(); }
ClientFacade implements Closeable { @Override public void close() { try { client.close(); } catch (ElasticsearchException e) { LOG.error("Error closing Elasticsearch client", e); } } ClientFacade(Client client); void createIndex(Index index, IndexSettings indexSettings, Stream<Mapping> mappingStream); boolean indexesExist(Index index); void deleteIndex(Index index); void refreshIndexes(); long getCount(Index index); long getCount(QueryBuilder query, Index index); SearchHits search(QueryBuilder query, int from, int size, List<Index> indexes); SearchHits search(QueryBuilder query, int from, int size, Sort sort, Index index); Aggregations aggregate(
      List<AggregationBuilder> aggregations, QueryBuilder query, Index index); Explanation explain(SearchHit searchHit, QueryBuilder query); void index(Index index, Document document); void deleteById(Index index, Document document); void processDocumentActions(Stream<DocumentAction> documentActions); @Override void close();  }