processPopularWordRequest(request, response, chain); L175: break; L176: case FAVORITE: L177: processFavoriteRequest(request, response, chain); L178: break; L179: case FAVORITES: L180: processFavoritesRequest(request, response, chain); L181: break; L182: case PING: L183: processPingRequest(request, response, chain); L184: break; L185: case SCROLL: L186: processScrollSearchRequest(request,...

if (response.hasError()) { L298: logger.warn("Failed to delete document words.", response.getErrors().get(0)); L299: return false; L300: } L301: refresh(); L302: return true; L303: } L304: L305: public boolean deleteQueryWords() { L306: final SuggestDeleteResponse response = suggester.indexer().deleteQueryWords(); L307: if (response.hasError()) { L308: logger.warn("Failed to delete query words.", response.getErrors().get(0));...

EngineUtil; L75:import org.dbflute.bhv.readable.EntityRowHandler; L76:import org.lastaflute.core.magic.async.AsyncManager; L77:import org.lastaflute.web.Execute; L78:import org.lastaflute.web.response.ActionResponse; L79:import org.lastaflute.web.response.HtmlResponse; L80:import org.lastaflute.web.response.StreamResponse; L81:import org.lastaflute.web.ruts.process.ActionRuntime; L82:import org.xml.sax.InputSource; L83: L84:import com.fasterxml.jackson.core.type.TypeReference; L85:import com.fas...

L1867: L1868: @Override L1869: public <Request extends ActionRequest, Response extends ActionResponse> ActionFuture<Response> execute( L1870: final ActionType<Response> action, final Request request) { L1871: return client.execute(action, request); L1872: } L1873: L1874: @Override L1875: public <Request extends ActionRequest, Response extends ActionResponse> void execute(final ActionType<Response> action, L1876: final Request request, final ActionListener<Response>...

ocumentSearchIndex()); L100: } L101: L102: protected void flush() { L103: if (bulkRequestBuilder != null) { L104: final BulkResponse response = bulkRequestBuilder.execute().actionGet(requestTimeout); L105: if (response.hasFailures()) { L106: logger.warn("Failed to update scores: {}", response.buildFailureMessage()); L107: } L108: bulkRequestBuilder = null; L109: } L110: } L111: L112: public int getPriority() { L113:...

(lowerPath.endsWith(".eot")) { L179: response.setContentType("application/vnd.ms-fontobject"); L180: } else if (lowerPath.endsWith(".ico")) { L181: response.setContentType("image/vnd.microsoft.icon"); L182: } else if (lowerPath.endsWith(".js")) { L183: response.setContentType("text/javascript"); L184: } else if (lowerPath.endsWith(".json")) { L185: response.setContentType("application/json"); L186: } else...

getDictionaryContent(final String path) { L1462: try (CurlResponse response = ComponentUtil.getCurlHelper().get("/_configsync/file").param("path", path).execute()) { L1463: if (response.getHttpStatusCode() == 200) { L1464: return response.getContentAsString(); L1465: } L1466: if (response.getContentException() != null) { L1467: logger.warn("{} is invalid path.", path, response.getContentException()); L1468: } else { L1469: ...

neClient().prepareUpdate().setIndex(fessConfig.getIndexDocumentUpdateIndex()).setId(id); L344: builderLambda.accept(builder); L345: final UpdateResponse response = builder.execute().actionGet(fessConfig.getIndexIndexTimeout()); L346: return response.getResult() == Result.CREATED || response.getResult() == Result.UPDATED; L347: } catch (final OpenSearchException e) { L348: throw new SearchEngineClientException("Failed to update doc " + id, e); L349:...

RequestUtil; L29:import org.lastaflute.web.validation.VaMessenger; L30: L31:import jakarta.servlet.http.HttpServletRequest; L32: L33:public class ApiResult { L34: L35: protected ApiResponse response = null; L36: L37: public ApiResult(final ApiResponse response) { L38: this.response = response; L39: } L40: L41: public enum Status { L42: OK(0), BAD_REQUEST(1), SYSTEM_ERROR(2), UNAUTHORIZED(3), FAILED(9); L43: L44: private final int id; L45: L46: Status(final...

final String index) { L311: final RefreshResponse response = searchEngineClient.admin().indices().prepareRefresh(index).execute().actionGet(); L312: if (logger.isDebugEnabled()) { L313: logger.debug("[{}] refresh status: {} ({}/{}/{})", index, response.getStatus(), response.getTotalShards(), L314: response.getSuccessfulShards(), response.getFailedShards()); L315: } L316: return response.getStatus().getStatus(); L317: } L318: L319: public...