} finally {
            Response curResp = response;
            Request curReq = request;
            while (curResp != null) {
                this.response_map.remove(curResp.getMid());
                final Request next = curReq.getNext();
                if (next == null) {
                    break;
                }
                curReq = next;

     */
    TimeZone getLocalTimezone();

    /**
     * Gets the process ID to use in SMB messages
     *
     * @return Process id to send, randomized if unset
     */
    int getPid();

    /**
     *
     * Property {@code jcifs.smb.client.maxMpxCount} (int, default 10)
     *
     * @return maximum count of concurrent commands to announce
     */
    int getMaxMpxCount();

        suggester.indexer().index(item);
        suggester.refresh();

        SuggestDeleteResponse deleteResponse = suggester.indexer().delete(item.getId());

        assertNotNull(deleteResponse);
        assertFalse(deleteResponse.hasError());
    }

    @Test
    public void test_deleteByQueryString() throws Exception {

            }
            cb.query().addOrderBy_CreatedTime_Asc();
            cb.fetchFirst(fessConfig.getPageThumbnailQueueMaxFetchSizeAsInteger());
        }).stream().map(entity -> {
            idList.add(entity.getId());
            if (!cleanup) {
                return executorService.submit(() -> process(fessConfig, entity));
            }
            if (logger.isDebugEnabled()) {

 *
 * {@snippet :
 * ListenableFuture<Boolean> adminIsLoggedIn =
 *     FluentFuture.from(usersDatabase.getAdminUser())
 *         .transform(User::getId, directExecutor())
 *         .transform(ActivityService::isLoggedIn, threadPool)
 *         .catching(RpcException.class, e -> false, directExecutor());
 * }
 *
 * <h3>Alternatives</h3>
 *
 * <h4>Frameworks</h4>

                            throw new ArtifactResolutionException(
                                    "Unable to get dependency information for " + artifact.getId() + ": "
                                            + e.getMessage(),
                                    artifact,
                                    childRemoteRepositories,
                                    e);

        assertEquals(1, response.getNum());
        assertEquals("検索 エンジン", response.getWords().get(0));

        suggester.indexer().delete(items[0].getId());
        suggester.refresh();
        SuggestResponse response2 = suggester.suggest().setQuery("kensaku").setSuggestDetail(true).execute().getResponse();
        assertEquals(0, response2.getNum());
    }

                            docMap.put(Constants.SCORE, score);
                        }
                    }

                    docMap.put(fessConfig.getIndexFieldId(), hit.getId());
                    docMap.put(fessConfig.getIndexFieldVersion(), hit.getVersion());
                    docMap.put(fessConfig.getIndexFieldSeqNo(), hit.getSeqNo());

                org.codelibs.fess.crawler.entity.ResultData resultData) {
            // Initialize test access result
        }

        @Override
        public String getId() {
            return "test_id";
        }

        @Override
        public String getSessionId() {
            return "test_session";
        }

        @Override
        public String getRuleId() {

                        }

                        if (!favoriteLogService.addUrl(userCode, (userInfo, favoriteLog) -> {
                            favoriteLog.setUserInfoId(userInfo.getId());
                            favoriteLog.setUrl(favoriteUrl);
                            favoriteLog.setDocId(docId);
                            favoriteLog.setQueryId(queryId);