*/
    private void emergencyCleanup() {
        try {
            // Force usage count to zero to trigger cleanup
            this.usageCount.set(0);

            synchronized (this) {
                // Emergency release of transport
                if (this.transportAcquired.compareAndSet(true, false)) {
                    try {
                        this.transport.release();

        /*
         * Note the Transport thread isn't running yet so we can
         * read from the socket here.
         */
        try {
            this.socket.setSoTimeout(this.transportContext.getConfig().getConnTimeout());
            if (peekKey() == null) { /* try to read header */
                throw new IOException("transport closed in negotiate");
            }
        } finally {

        // Try RFC 1123 format first
        try {
            final Instant instant = Instant.from(RFC_1123_FORMATTER.parse(value));
            return Date.from(instant);
        } catch (final DateTimeParseException e) {
            // Try fallback
        }
        // Fallback to custom pattern for non-standard formats (e.g., single-digit day)
        try {

    protected Date parseLastModifiedDate(final String value) {
        // Try Apache DateUtils first (handles standard HTTP date formats)
        final Date date = DateUtils.parseDate(value);
        if (date != null) {
            return date;
        }
        // Fallback to custom pattern for non-standard formats (e.g., single-digit day)
        try {
            return DATE_FORMAT_HOLDER.get().parse(value);

        request.setAttribute(Constants.SEARCH_LOG_ACCESS_TYPE, Constants.SEARCH_LOG_ACCESS_TYPE_JSON);
        final JsonRequestParams params = new JsonRequestParams(request, fessConfig);
        try {
            response.setContentType("application/x-ndjson; charset=UTF-8");
            final long count = searchHelper.scrollSearch(params, doc -> {
                buf.setLength(0);
                buf.append('{');

                executor.execute(() -> {
                    try {
                        executeStep(step);
                        if (nextIsPlanning) {
                            lock.writeLock().lock();
                            try {
                                plan();
                            } finally {

     */
    @Override
    protected void storeData(final ResponseData responseData, final ResultData resultData) {
        final DOMParser parser = getDomParser();
        try (final BufferedInputStream bis = new BufferedInputStream(responseData.getResponseBody())) {
            final byte[] bomBytes = new byte[UTF8_BOM_SIZE];
            bis.mark(UTF8_BOM_SIZE);

                  assertThat(peeker.getDone(input1)).isSameInstanceAs("value1");
                  try {
                    peeker.getDone(input2Failed);
                    fail("Peeker.getDone() should fail for failed inputs");
                  } catch (ExecutionException expected) {
                  }
                  try {
                    peeker.getDone(nonInput);

                  assertThat(peeker.getDone(input1)).isSameInstanceAs("value1");
                  try {
                    peeker.getDone(input2Failed);
                    fail("Peeker.getDone() should fail for failed inputs");
                  } catch (ExecutionException expected) {
                  }
                  try {
                    peeker.getDone(nonInput);

            try {
                model = modelProcessor.read(modelSource.getInputStream(), options);
            } catch (ModelParseException e) {
                if (!strict) {
                    throw e;
                }

                options.put(ModelProcessor.IS_STRICT, Boolean.FALSE);

                try {