protected static class ComponentHolder<T> {
        /**
         * The component instance being held.
         */
        protected T instance;

        /**
         * The destroyer function to be called when the component is destroyed.
         */
        protected Consumer<T> destroyer;

        /**
         * Creates a new ComponentHolder with the specified instance and destroyer.

     */
    public ApiExtractor() {
        // NOP
    }

    /**
     * Initializes the API extractor, setting up the HTTP client and configuration.
     * This method is called after construction to initialize the HTTP client with
     * configured timeouts, authentication, and request headers.
     */
    @PostConstruct
    public void init() {
        if (logger.isDebugEnabled()) {

     */
    public HtmlXpathExtractor() {
        super();
    }

    /**
     * Initializes the XPathAPI cache with a specified cache duration.
     * This method is called to set up the cache for XPathAPI instances.
     */
    @Resource
    public void init() {
        xpathAPICache =

        urlQueueService.delete(sessionId);
        dataService.delete(sessionId);
        urlFilter.clear();
    }

    /**
     * Closes the crawler, releasing resources.
     * This method is called automatically when the crawler is used in a try-with-resources statement.
     */
    @Override
    public void close() {
        clientFactory.close();
    }

    /**

            public void onDestroy(PooledObject<TestComponent> p) {
                listenerCalled.set(true);
            }
        });

        factory.destroyObject(null);

        // Listener should be called even with null
        assertTrue(listenerCalled.get());
    }

    /**
     * Test destroyObject with exception in listener
     */
    public void test_destroyObject_listenerException() {

            prepareClearScroll().addScrollId(scrollId)
                    .execute(ActionListener.wrap(res -> {}, e -> logger.warn("Failed to clear " + scrollId, e)));
        }
    }

    /**
     * Listener for connection events.
     */
    public interface OnConnectListener {
        /**
         * Called when the client connects to OpenSearch.
         */
        void onConnect();
    }

    /**

                        logger.warn("Failed to set originalOutStream.", e);
                    }
                }
                if (originalErrStream != null) {
                    try {
                        System.setErr(originalErrStream);
                    } catch (Exception e) {
                        logger.warn("Failed to set originalErrStream.", e);
                    }
                }

                    if (logger.isDebugEnabled()) {
                        logger.warn("[{}][{}] Failed to analyze a text(size:{}).", field, lang, buf.length(), e);
                    } else {
                        logger.warn("[{}][{}] Failed to analyze a text(size:{}). {}", field, lang, buf.length(), e.getMessage());
                    }
                }
                buf.setLength(0);

                throw new CrawlingAccessException("[" + e.status() + "] Failed to insert " + id, e);
            }
            throw new OpenSearchAccessException("[" + e.status() + "] Failed to insert " + id, e);
        } catch (final Exception e) {
            throw new OpenSearchAccessException("Failed to insert " + id, e);
        }
    }

    /**

            client.admin().indices().prepareRefresh().setIndices(actualIndex).execute().actionGet(settings.getIndicesTimeout());
        } catch (final Exception e) {
            throw new SuggestSettingsException("Failed to add to array.", e);
        }
    }

    /**
     * Delete values from array index.
     * @param index Index
     * @param type Type
     * @param key Key
     */