Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 76 for listener2 (0.07 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/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)
  3. android/guava/src/com/google/common/util/concurrent/Service.java

       * across calls to multiple listeners. Specifically, a given listener will have its callbacks
       * invoked in the same order as the underlying service enters those states. Additionally, at most
       * one of the listener's callbacks will execute at once. However, multiple listeners' callbacks
       * may execute concurrently, and listeners may execute in an order different from the one in which
       * they were registered.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  4. 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)
  5. guava/src/com/google/common/util/concurrent/Service.java

       * across calls to multiple listeners. Specifically, a given listener will have its callbacks
       * invoked in the same order as the underlying service enters those states. Additionally, at most
       * one of the listener's callbacks will execute at once. However, multiple listeners' callbacks
       * may execute concurrently, and listeners may execute in an order different from the one in which
       * they were registered.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  6. 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)
  7. guava/src/com/google/common/util/concurrent/AbstractService.java

       * @since 13.0
       */
      @Override
      public final void addListener(Listener listener, Executor executor) {
        listeners.addListener(listener, executor);
      }
    
      @Override
      public String toString() {
        return getClass().getSimpleName() + " [" + state() + "]";
      }
    
      /**
       * Attempts to execute all the listeners in {@link #listeners} while not holding the {@link
       * #monitor}.
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractService.java

       * @since 13.0
       */
      @Override
      public final void addListener(Listener listener, Executor executor) {
        listeners.addListener(listener, executor);
      }
    
      @Override
      public String toString() {
        return getClass().getSimpleName() + " [" + state() + "]";
      }
    
      /**
       * Attempts to execute all the listeners in {@link #listeners} while not holding the {@link
       * #monitor}.
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.3K 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