- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 53 for setSessionId (0.05 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/UrlQueueServiceImpl.java
final Queue<UrlQueueImpl<Long>> urlQueueList = dataHelper.getUrlQueueList(sessionId); synchronized (urlQueueList) { final UrlQueueImpl<Long> urlQueue = new UrlQueueImpl<>(); urlQueue.setSessionId(sessionId); urlQueue.setMethod(Constants.GET_METHOD); urlQueue.setUrl(url); urlQueue.setDepth(0); urlQueue.setCreateTime(SystemUtil.currentTimeMillis());
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 9.3K bytes - Viewed (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataServiceTest.java
accessResult1.setMethod("GET"); accessResult1.setMimeType("text/plain"); accessResult1.setParentUrl("http://www.parent.com/"); accessResult1.setRuleId("htmlRule"); accessResult1.setSessionId("id1"); accessResult1.setStatus(200); accessResult1.setUrl("http://www.id1.com/"); dataService.store(accessResult1);
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Mar 15 06:52:00 UTC 2025 - 6.8K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/ServerMessageBlock2Test.java
} @Test @DisplayName("Should get and set session ID") void testSessionIdProperty() { assertEquals(0, testMessage.getSessionId()); testMessage.setSessionId(789L); assertEquals(789L, testMessage.getSessionId()); } @Test @DisplayName("Should propagate session ID to chained message") void testSessionIdPropagation() {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 39.5K bytes - Viewed (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java
urlQueue.setSessionId("id1"); urlQueue.setUrl("http://www.id1.com/"); urlQueueService.insert(urlQueue); final OpenSearchUrlQueue urlQueue2 = new OpenSearchUrlQueue(); urlQueue2.setCreateTime(System.currentTimeMillis()); urlQueue2.setDepth(1); urlQueue2.setMethod("GET"); urlQueue2.setSessionId("id2");
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 5.8K bytes - Viewed (0) -
src/test/java/jcifs/internal/CommonServerMessageBlockTest.java
} @Test @DisplayName("Test setSessionId method") void testSetSessionId() { // Given long sessionId = 987654321L; doNothing().when(messageBlock).setSessionId(sessionId); // When messageBlock.setSessionId(sessionId); // Then verify(messageBlock).setSessionId(sessionId); } @Test
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.7K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/Smb2TransformHeaderTest.java
assertEquals(flags, transformHeader.getFlags()); } @Test @DisplayName("Should set and get session ID") void testSessionId() { // When transformHeader.setSessionId(testSessionId); // Then assertEquals(testSessionId, transformHeader.getSessionId()); } @Test @DisplayName("Should encode transform header to byte buffer")
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 12.7K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlFilterService.java
*/ @Override public void addIncludeUrlFilter(final String sessionId, final String url) { final OpenSearchUrlFilter esUrlFilter = new OpenSearchUrlFilter(); esUrlFilter.setSessionId(sessionId); esUrlFilter.setFilterType(INCLUDE); esUrlFilter.setUrl(url); insert(esUrlFilter, OpType.INDEX); includeFilterCache.invalidate(sessionId); } /**
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 9.2K 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 Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 6.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/session/Smb2SessionSetupRequest.java
* {@inheritDoc} * * @see jcifs.internal.smb2.ServerMessageBlock2#chain(jcifs.internal.smb2.ServerMessageBlock2) */ @Override public boolean chain(final ServerMessageBlock2 n) { n.setSessionId(Smb2Constants.UNSPECIFIED_SESSIONID); return super.chain(n); } /** * {@inheritDoc} * * @see jcifs.internal.CommonServerMessageBlockRequest#size() */ @Override
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.8K bytes - Viewed (0) -
README.md
### Multi-Instance Crawling ```java // Create multiple crawler instances Crawler crawler1 = container.getComponent("crawler"); crawler1.setSessionId("session1"); crawler1.addUrl("https://site1.com"); Crawler crawler2 = container.getComponent("crawler"); crawler2.setSessionId("session2"); crawler2.addUrl("https://site2.com"); // Execute concurrently crawler1.setBackground(true); crawler2.setBackground(true);
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Aug 31 05:32:52 UTC 2025 - 15.3K bytes - Viewed (0)