- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 63 for queueMsg (0.04 sec)
-
src/main/java/org/codelibs/fess/indexer/IndexUpdater.java
finishedSessionIdList.add(sessionId); } } /** * Deletes all data associated with a specific crawler session. * Removes URL filters, URL queues, and access result data for the session. * * @param sessionId the session ID whose data should be deleted */ private void deleteBySessionId(final String sessionId) { try {
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 32.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java
import java.util.LinkedList; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /** * Tests for {@link Synchronized#deque} and {@link Queues#synchronizedDeque}. * * @author Kurt Alfred Kluever */ @NullUnmarked public class SynchronizedDequeTest extends TestCase { protected Deque<String> create() { TestDeque<String> inner = new TestDeque<>();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 7.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java
import java.util.Queue; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /** * Tests for {@link Synchronized#queue} and {@link Queues#synchronizedQueue}. * * @author Kurt Alfred Kluever */ @NullUnmarked public class SynchronizedQueueTest extends TestCase { protected Queue<String> create() { TestQueue<String> inner = new TestQueue<>();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 4.8K bytes - Viewed (0) -
internal/event/config.go
return &ErrUnknownRegion{q.ARN.region} } if !targetList.Exists(q.ARN.TargetID) { return &ErrARNNotFound{q.ARN} } return nil } // SetRegion - sets region value to queue's ARN. func (q *Queue) SetRegion(region string) { q.ARN.region = region } // ToRulesMap - converts Queue to RulesMap func (q Queue) ToRulesMap() RulesMap { pattern := q.Filter.RuleList.Pattern()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java
import java.util.LinkedList; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /** * Tests for {@link Synchronized#deque} and {@link Queues#synchronizedDeque}. * * @author Kurt Alfred Kluever */ @NullUnmarked public class SynchronizedDequeTest extends TestCase { protected Deque<String> create() { TestDeque<String> inner = new TestDeque<>();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 7.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/package-info.java
* <li>{@link Iterators} * <li>{@link Lists} * <li>{@link Maps} * <li>{@link MoreCollectors} * <li>{@link Multimaps} * <li>{@link Multisets} * <li>{@link ObjectArrays} * <li>{@link Queues} * <li>{@link Sets} * <li>{@link Streams} * <li>{@link Tables} * </ul> * * <h2>Abstract implementations</h2> * * <ul> * <li>{@link AbstractIterator}
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 14:50:24 UTC 2024 - 5K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/EvictingQueue.java
* * <p>An evicting queue must be configured with a maximum size. Each time an element is added to a * full queue, the queue automatically removes its head element. This is different from conventional * bounded queues, which either block or reject new elements when full. * * <p>This class is not thread-safe, and does not accept null elements. * * @author Kurt Alfred Kluever * @since 15.0 */ @GwtCompatible
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Feb 13 17:34:21 UTC 2025 - 4.6K bytes - Viewed (0) -
cmd/bucket-notification-handlers.go
if err = config.Validate(region, globalEventNotifier.targetList); err != nil { arnErr, ok := err.(*event.ErrARNNotFound) if ok { for i, queue := range config.QueueList { // Remove ARN not found queues, because we previously allowed // adding unexpected entries into the config. // // With newer config disallowing changing / turning off // notification targets without removing ARN in notification
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt
"FINE: Q10000 finished run in 0 µs: task one", ) } /** * The runner doesn't hold references to its queues! Otherwise we'd need a mechanism to clean them * up when they're no longer needed and that's annoying. Instead the task runner only tracks which * queues have work scheduled. */ @Test fun activeQueuesContainsOnlyQueuesWithScheduledTasks() { redQueue.execute("task one", 100.µs) {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 23K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/service/impl/UrlQueueServiceImplTest.java
// Execute service.generateUrlQueues(previousSessionId, sessionId); // Verify assertEquals(2, newQueue.size()); // Verify the generated queues have correct properties List<UrlQueueImpl<Long>> queueList = new ArrayList<>(newQueue); boolean foundPage1 = false; boolean foundPage2 = false;Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 13 13:29:22 UTC 2025 - 14.1K bytes - Viewed (0)