Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for buildFailureMessage (0.07 sec)

  1. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

                    if (response.hasFailures()) {
                        final String failureMessage = buildFailureMessage(response, ignoreAlreadyExists);
                        if (failureMessage.length() > 0) {
                            failureBuf.append(response.buildFailureMessage()).append('\n');
                        }
                    }
                    bufferedList.clear();
                }
            });
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 34.2K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

                        }
    
                        return builder.execute();
                    });
                    if (bulkResponse.hasFailures()) {
                        throw new OpenSearchAccessException(bulkResponse.buildFailureMessage());
                    }
    
                    final String sid = scrollId;
                    response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute());
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/score/ScoreBooster.java

                final BulkResponse response = bulkRequestBuilder.execute().actionGet(requestTimeout);
                if (response.hasFailures()) {
                    logger.warn("Failed to update scores: {}", response.buildFailureMessage());
                }
                bulkRequestBuilder = null;
            }
        }
    
        /**
         * Gets the priority of this score booster.
         * @return The priority.
         */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractBehavior.java

                    final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout);
                    if (bulkResponse.hasFailures()) {
                        throw new IllegalBehaviorStateException(bulkResponse.buildFailureMessage());
                    }
    
                    response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout);
                    if (!scrollId.equals(response.getScrollId())) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jun 21 04:02:44 UTC 2025
    - 26.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/helper/IndexingHelper.java

                                    }
                                }
                            }
                        }
                        throw new SearchEngineClientException(response.buildFailureMessage());
                    }
                }
                if (logger.isInfoEnabled()) {
                    if (docList.getContentSize() > 0) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 26.1K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractBehavior.java

                    final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout);
                    if (bulkResponse.hasFailures()) {
                        throw new IllegalBehaviorStateException(bulkResponse.buildFailureMessage());
                    }
    
                    response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout);
                    if (!scrollId.equals(response.getScrollId())) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jun 21 04:02:44 UTC 2025
    - 26.4K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java

                        if (bulkResponse.hasFailures()) {
                            throw new SuggesterException(bulkResponse.buildFailureMessage());
                        }
                        response = client.prepareSearchScroll(scrollId)
                                .setScroll(settings.getScrollTimeout())
                                .execute()
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Mon Sep 01 13:33:03 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/helper/SearchHelper.java

            consumer.accept(builder);
            try {
                final BulkResponse response = builder.execute().get();
                if (response.hasFailures()) {
                    throw new SearchEngineClientException(response.buildFailureMessage());
                }
                return true;
            } catch (final InterruptedException e) {
                throw new InterruptedRuntimeException(e);
            } catch (final ExecutionException e) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 35.8K bytes
    - Viewed (0)
  9. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

                        }
                        return bulkRequest.execute();
                    });
                    if (bulkResponse.hasFailures()) {
                        throw new OpenSearchAccessException(bulkResponse.buildFailureMessage());
                    }
    
                    final String sid = scrollId;
                    response = get(c -> c.prepareSearchScroll(sid).setScroll(scrollForDelete).execute());
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Aug 31 05:32:52 UTC 2025
    - 25.3K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/opensearch/log/allcommon/EsAbstractBehavior.java

                    final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout);
                    if (bulkResponse.hasFailures()) {
                        throw new IllegalBehaviorStateException(bulkResponse.buildFailureMessage());
                    }
    
                    response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout);
                    if (!scrollId.equals(response.getScrollId())) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jun 21 04:02:44 UTC 2025
    - 26.4K bytes
    - Viewed (0)
Back to top