* Supports sequential (default) and random ordering based on crawling configuration.
     *
     * @param sessionId the crawling session identifier
     * @return list of URL queue entries for processing
     */
    @Override
    protected List<OpenSearchUrlQueue> fetchUrlQueueList(final String sessionId) {
        final CrawlingConfigHelper crawlingConfigHelper = ComponentUtil.getCrawlingConfigHelper();

     *
     * @param sessionId the session identifier to find the latest crawling parameters for
     * @return a list of CrawlingInfoParam entities from the latest session, or empty list if none found
     */
    public List<CrawlingInfoParam> getLastCrawlingInfoParamList(final String sessionId) {
        final CrawlingInfo crawlingInfo = getLast(sessionId);
        if (crawlingInfo == null) {

    /**
     * Offers all URL queues.
     *
     * @param sessionId The session ID.
     * @param newUrlQueueList The list of new URL queues.
     */
    void offerAll(String sessionId, List<QUEUE> newUrlQueueList);

    /**
     * Polls a URL queue.
     *
     * @param sessionId The session ID.
     * @return The URL queue.
     */
    QUEUE poll(String sessionId);

    /**
     * Saves the session.
     *

            public void offerAll(String sessionId, List<UrlQueue<?>> newUrlQueueList) {
            }

            @Override
            public UrlQueue<?> poll(String sessionId) {
                return null;
            }

            @Override
            public void saveSession(String sessionId) {
            }

            @Override
            public boolean visited(UrlQueue<?> urlQueue) {

    public void setSessionId_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda) {
        setSessionId_Terms("sessionId", opLambda, null);
    }

    public void setSessionId_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda, OperatorCall<BsCrawlingInfoCA> aggsLambda) {
        setSessionId_Terms("sessionId", opLambda, aggsLambda);
    }

        // Generate unique session ID for key management
        this.sessionId = String.format("smb-enc-%d-%d", System.currentTimeMillis(), secureRandom.nextLong());

        if (keyManager != null) {
            // Store keys securely
            String encKeyId = sessionId + "-enc";
            String decKeyId = sessionId + "-dec";
            keyManager.storeSessionKey(encKeyId, encryptionKey, "AES");

     * @param sessionId the session ID
     * @return the URL queue for the session
     */
    public synchronized Queue<UrlQueueImpl<Long>> getUrlQueueList(final String sessionId) {
        Queue<UrlQueueImpl<Long>> urlQueueList = urlQueueMap.get(sessionId);
        if (urlQueueList == null) {
            urlQueueList = new LinkedList<>();
            urlQueueMap.put(sessionId, urlQueueList);
        }

     * @param sessionId The session ID.
     */
    @Override
    public void delete(final String sessionId) {
        deleteBySessionId(sessionId);
        includeFilterCache.invalidate(sessionId);
        excludeFilterCache.invalidate(sessionId);
    }

    /**
     * Gets the list of include URL patterns for the specified session.
     *
     * @param sessionId The session ID.

     * @return The session ID.
     */
    public String getSessionId() {
        return sessionId;
    }

    /**
     * Sets the session ID.
     * @param sessionId The session ID.
     */
    public void setSessionId(final String sessionId) {
        this.sessionId = sessionId;
    }

    /**
     * Returns the active thread count.
     * @return The active thread count.
     */

        sessionContexts.put(sessionId, context);

        log.debug("Initialized preauth integrity context for session {}", sessionId);
        return context;
    }

    /**
     * Updates the preauth integrity hash with a new message.
     *
     * @param sessionId the session identifier
     * @param messageData the message data to include in hash