- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for SessionId (0.1 sec)
-
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/entity/OpenSearchUrlFilter.java
public void setId(final String id) { this.id = id; } public String getSessionId() { return sessionId; } public void setSessionId(final String sessionId) { this.sessionId = sessionId; } public String getFilterType() { return filterType; } public void setFilterType(final String filterType) { this.filterType = filterType; }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 2.1K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
final Object sessionId = sessionIdProp.getValue(target); return sessionId == null ? null : sessionId.toString(); } private String getSessionId(final Object target) { final BeanDesc beanDesc = BeanDescFactory.getBeanDesc(target.getClass()); final PropertyDesc sessionIdProp = beanDesc.getPropertyDesc(SESSION_ID); final Object sessionId = sessionIdProp.getValue(target);
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 23.6K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
} } @Override public void delete(final String sessionId) { deleteBySessionId(sessionId); } @Override public void offerAll(final String sessionId, final List<OpenSearchUrlQueue> urlQueueList) { if (logger.isDebugEnabled()) { logger.debug("Offering URL: Session ID: {}, UrlQueue: {}", sessionId, urlQueueList); }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 13.4K bytes - Viewed (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java
urlQueue.setSessionId("sessionId"); urlQueue.setUrl("http://www.example.com/"); urlQueueService.insert(urlQueue); assertTrue(fesenClient.prepareSearch("fess_crawler.queue").setQuery(QueryBuilders.termQuery("sessionId", "sessionId")).setSize(0) .execute().actionGet().getHits().getTotalHits().value > 0); urlQueueService.delete("sessionId");
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 5.1K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlFilterService.java
excludeFilterCache.invalidate(sessionId); } @Override public List<Pattern> getIncludeUrlPatternList(final String sessionId) { try { return includeFilterCache.get(sessionId); } catch (final ExecutionException e) { throw new CrawlerSystemException(e); } } @Override
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 6.3K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/UrlQueueImpl.java
*/ @Override public String getSessionId() { return sessionId; } /* * (non-Javadoc) * * @see org.codelibs.fess.crawler.entity.UrlQueue#setSessionId(java.lang.String) */ @Override public void setSessionId(final String sessionId) { this.sessionId = sessionId; } /* * (non-Javadoc) *
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Mon Nov 04 07:44:18 UTC 2024 - 5.2K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/entity/OpenSearchUrlQueue.java
@Override public XContentBuilder toXContent(final XContentBuilder builder, final Params params) throws IOException { builder.startObject(); if (sessionId != null) { builder.field(SESSION_ID, sessionId); } if (method != null) { builder.field(METHOD, method); } if (url != null) { builder.field(URL, url); }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 2.2K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java
} @Override public int getCount(final String sessionId) { return getCount(builder -> builder.setQuery(QueryBuilders.termQuery(SESSION_ID, sessionId))); } @Override public void delete(final String sessionId) { deleteBySessionId(sessionId); } @Override public OpenSearchAccessResult getAccessResult(final String sessionId, final String url) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 8.5K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/entity/OpenSearchAccessResult.java
} @Override public XContentBuilder toXContent(final XContentBuilder builder, final Params params) throws IOException { builder.startObject(); if (sessionId != null) { builder.field(SESSION_ID, sessionId); } if (ruleId != null) { builder.field(RULE_ID, ruleId); } if (url != null) { builder.field(URL, url); }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 4.6K bytes - Viewed (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
crawler.getCrawlerContext().setNumOfThread(numOfThread); crawler.urlFilter.addInclude(url + ".*"); final String sessionId = crawler.execute(); assertEquals(maxCount, dataService.getCount(sessionId)); dataService.delete(sessionId); } finally { server.stop(); } } public void test_execute_2instanceTx() throws Exception {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 7.7K bytes - Viewed (0)