@Resource
    protected SessionManager sessionManager;

    /** Configuration manager for Fess application settings. */
    @Resource
    protected FessConfig fessConfig;

    /** Helper for managing user activity logging and tracking. */
    @Resource
    protected ActivityHelper activityHelper;

    /** Manager for handling HTTP response operations. */
    @Resource
    protected ResponseManager responseManager;

            assertTrue(executor.awaitTermination(5, TimeUnit.SECONDS));

            // Some operations might succeed before key wipe, some might fail after
            // At minimum, we expect some activity (not all operations should be no-ops)
            int totalOperations = successCount.get() + failureCount.get();
            assertTrue(totalOperations > 0, "Some signing/verification operations should have been attempted");

    /**
     * Channel is established and ready for use
     */
    ESTABLISHED(3),

    /**
     * Channel binding in progress
     */
    BINDING(4),

    /**
     * Channel is actively transferring data
     */
    ACTIVE(5),

    /**
     * Channel connection has failed
     */
    FAILED(6),

    /**
     * Channel is being closed
     */
    CLOSING(7);

 * If the time since the last request to the host is less than the configured delay,
 * the thread waits until the delay has elapsed.
 * This class is thread-safe.
 * The cache automatically evicts entries after 1 hour of inactivity to prevent memory leaks.
 */
public class HostIntervalController extends DefaultIntervalController {

    /** Default cache expire duration in hours */
    private static final long DEFAULT_CACHE_EXPIRE_HOURS = 1L;

             * The NbtAddress object used to query this node will be in the list
             * returned by the Node Status. A new NbtAddress object should not be
             * created for it because the original is potentially being actively
             * referenced by other objects. We must populate the existing object's
             * data explicitly (and carefully).
             */
            if (!addrFound && this.queryAddress.hostName.hexCode == hexCode

                 * returned by the Node Status. A new NbtAddress object should not be
                 * created for it because the original is potentially being actively
                 * referenced by other objects. We must populate the existing object's
                 * data explicitly (and carefully).
                 */

            return initParamMap.getAsString(Constants.CRAWLING_INFO_ID);
        }

        /**
         * Checks if the crawling thread is currently running.
         *
         * @return true if the thread is actively executing
         */
        public boolean isRunning() {
            return running;
        }

        /**
         * Waits for the crawling thread to terminate.

    CONNECTING(1),       // Connection in progress
    AUTHENTICATING(2),   // Authentication in progress
    ESTABLISHED(3),      // Ready for use
    BINDING(4),         // Channel binding in progress
    ACTIVE(5),          // Actively transferring data
    FAILED(6),          // Connection failed
    CLOSING(7);         // Closing connection
    
    private final int value;
    
    ChannelState(int value) {
        this.value = value;
    }