Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 111 for listener2 (0.06 sec)

  1. fess-crawler/src/test/java/org/codelibs/fess/crawler/pool/CrawlerPooledObjectFactoryTest.java

            // Test with listener1
            factory.setOnDestroyListener(listener1);
            assertEquals(listener1, factory.getOnDestroyListener());
            factory.destroyObject(pooledObject);
            assertEquals(1, events.size());
            assertEquals("listener1", events.get(0));
    
            // Switch to listener2
            factory.setOnDestroyListener(listener2);
            assertEquals(listener2, factory.getOnDestroyListener());
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Wed Sep 03 14:42:53 UTC 2025
    - 19.3K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/job/JobExecutorTest.java

            };
    
            ShutdownListener listener2 = new ShutdownListener() {
                @Override
                public void onShutdown() {
                    callCount.addAndGet(10);
                }
            };
    
            // Add first listener
            jobExecutor.addShutdownListener(listener1);
            assertEquals(listener1, jobExecutor.shutdownListener);
    
            // Replace with second listener
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        queue.enqueue(incrementingEvent(counters, listener1, 1));
        queue.enqueue(incrementingEvent(counters, listener1, 2));
    
        Object listener2 = new Object();
        queue.addListener(listener2, directExecutor());
        queue.enqueue(incrementingEvent(counters, multiset(listener1, 3, listener2, 1)));
        queue.enqueue(incrementingEvent(counters, multiset(listener1, 4, listener2, 2)));
        assertEquals(0, counters.size());
        queue.dispatch();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        queue.enqueue(incrementingEvent(counters, listener1, 1));
        queue.enqueue(incrementingEvent(counters, listener1, 2));
    
        Object listener2 = new Object();
        queue.addListener(listener2, directExecutor());
        queue.enqueue(incrementingEvent(counters, multiset(listener1, 3, listener2, 1)));
        queue.enqueue(incrementingEvent(counters, multiset(listener1, 4, listener2, 2)));
        assertEquals(0, counters.size());
        queue.dispatch();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/job/impl/ScriptExecutorTest.java

            // Add second listener (should replace first)
            TestShutdownListener listener2 = new TestShutdownListener();
            scriptExecutor.addShutdownListener(listener2);
    
            // Call shutdown
            scriptExecutor.shutdown();
    
            // Verify only second listener was called
            assertFalse(listener1.wasShutdownCalled());
            assertTrue(listener2.wasShutdownCalled());
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

        void enqueueStoppedEvent() {
          listeners.enqueue(STOPPED_EVENT);
        }
    
        void enqueueHealthyEvent() {
          listeners.enqueue(HEALTHY_EVENT);
        }
    
        void enqueueFailedEvent(Service service) {
          listeners.enqueue(
              new ListenerCallQueue.Event<Listener>() {
                @Override
                public void call(Listener listener) {
                  listener.failure(service);
                }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  7. src/main/java/jcifs/util/SmbCircuitBreaker.java

        }
    
        /**
         * Add a listener for circuit breaker events
         *
         * @param listener the listener to add
         */
        public void addListener(CircuitBreakerListener listener) {
            if (listener != null) {
                listeners.add(listener);
            }
        }
    
        /**
         * Remove a listener
         *
         * @param listener the listener to remove
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

       */
      public void addListener(L listener, Executor executor) {
        checkNotNull(listener, "listener");
        checkNotNull(executor, "executor");
        listeners.add(new PerListenerQueue<>(listener, executor));
      }
    
      /**
       * Enqueues an event to be run on currently known listeners.
       *
       * <p>The {@code toString} method of the Event itself will be used to describe the event in the
       * case of an error.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  9. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java

            return updateScope;
        }
    
        private void fireEvent(int event, List<ResolutionListener> listeners, ResolutionNode node) {
            fireEvent(event, listeners, node, null);
        }
    
        private void fireEvent(int event, List<ResolutionListener> listeners, ResolutionNode node, Artifact replacement) {
            fireEvent(event, listeners, node, replacement, null);
        }
    
        private void fireEvent(
                int event,
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 36.5K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/witness/WitnessClient.java

                    WitnessNotificationListener listener = listeners.get(entry.getKey());
                    if (listener != null) {
                        try {
                            listener.onWitnessNotification(notification);
                        } catch (Exception e) {
                            log.error("Error in witness notification listener", e);
                        }
                    }
                }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 20.8K bytes
    - Viewed (0)
Back to top