@Test(expected = InternalErrorException.class) public void failedProcessRequest() { Request request = new Request(HttpPut.METHOD_NAME, TestConstants.DUMMY_ENDPOINT); when(mockESClient.performRequest(any())).thenThrow(new InternalErrorException(TestConstants.DUMMY_ERROR_MESSAGE)); test.processRequest(request, mockLogger); }
@Override public Response processRequest(@NonNull final Request request, @NonNull final LambdaLogger logger) { logger.log("Default Elasticsearch requests detected"); return esClient.performRequest(request); }
DefaultProcessor implements ElasticsearchProcessor { @Override public Response processRequest(@NonNull final Request request, @NonNull final LambdaLogger logger) { logger.log("Default Elasticsearch requests detected"); return esClient.performRequest(request); } }
DefaultProcessor implements ElasticsearchProcessor { @Override public Response processRequest(@NonNull final Request request, @NonNull final LambdaLogger logger) { logger.log("Default Elasticsearch requests detected"); return esClient.performRequest(request); }  }
DefaultProcessor implements ElasticsearchProcessor { @Override public Response processRequest(@NonNull final Request request, @NonNull final LambdaLogger logger) { logger.log("Default Elasticsearch requests detected"); return esClient.performRequest(request); }  @Override Response processRequest(@NonNull final Request request, @NonNull final LambdaLogger logger); }
DefaultProcessor implements ElasticsearchProcessor { @Override public Response processRequest(@NonNull final Request request, @NonNull final LambdaLogger logger) { logger.log("Default Elasticsearch requests detected"); return esClient.performRequest(request); }  @Override Response processRequest(@NonNull final Request request, @NonNull final LambdaLogger logger);  }