callable, Executor executor) { L152: checkNotNull(callable); L153: checkNotNull(executor); L154: return submitAsync( L155: new AsyncCallable<T>() { L156: @Override L157: public ListenableFuture<T> call() throws Exception { L158: return immediateFuture(callable.call()); L159: } L160: L161: @Override L162: public String toString() { L163: return callable.toString(); L164: } L165: }, L166: executor);...

org.codelibs.core.crypto.CachedCipher; L30:import org.codelibs.core.lang.StringUtil; L31:import org.codelibs.fess.app.service.AccessTokenService; L32:import org.codelibs.fess.entity.SearchRequestParams.SearchRequestType; L33:import org.codelibs.fess.exception.InvalidAccessTokenException; L34:import org.codelibs.fess.mylasta.action.FessUserBean; L35:import org.codelibs.fess.mylasta.direction.FessConfig; L36:import org.codelibs.fess.util.ComponentUtil; L37:import org.lastaflute.web.login.LoginManager; L38:import...

org.codelibs.curl.Curl.Method; L32:import org.codelibs.curl.CurlRequest; L33:import org.codelibs.curl.CurlResponse; L34:import org.codelibs.fess.Constants; L35:import org.codelibs.fess.api.BaseApiManager; L36:import org.codelibs.fess.exception.FessSystemException; L37:import org.codelibs.fess.exception.WebApiException; L38:import org.codelibs.fess.mylasta.action.FessUserBean; L39:import org.codelibs.fess.util.ComponentUtil; L40:import org.codelibs.fess.util.ResourceUtil; L41:import org.lastaflute.web.servlet.request.RequestManager;...

.expireAfterWrite(userCheckInterval, TimeUnit.MILLISECONDS)// L97: .build(new CacheLoader<String, UserInfo>() { L98: @Override L99: public UserInfo load(final String key) throws Exception { L100: return storeUserInfo(key); L101: } L102: }); L103: searchLogLogger = LogManager.getLogger(loggerName); L104: } L105: L106: public void addSearchLog(final SearchRequestParams...

Manager; L89:import org.lastaflute.core.message.MessageManager; L90:import org.lastaflute.core.security.PrimaryCipher; L91:import org.lastaflute.di.core.SingletonLaContainer; L92:import org.lastaflute.di.core.exception.AutoBindingFailureException; L93:import org.lastaflute.di.core.exception.ComponentNotFoundException; L94:import org.lastaflute.di.core.factory.SingletonLaContainerFactory; L95:import org.lastaflute.di.core.smart.hot.HotdeployUtil; L96:import org.lastaflute.job.JobManager; L97:import...

final IntervalControlHelper intervalControlHelper = ComponentUtil.getIntervalControlHelper(); L61: intervalControlHelper.checkCrawlerStatus(); L62: intervalControlHelper.delayByRules(); L63: } catch (final Exception e) {} L64: L65: super.delayForWaitingNewUrl(); L66: } L67:}...

java.util.Map; L20: L21:import org.codelibs.fess.unit.UnitFessTestCase; L22: L23:public class LanguageHelperTest extends UnitFessTestCase { L24: L25: private LanguageHelper languageHelper; L26: L27: @Override L28: public void setUp() throws Exception { L29: super.setUp(); L30: languageHelper = new LanguageHelper(); L31: languageHelper.langFields = new String[] { "title", "content" }; L32: } L33: L34: public void test_createScript() { L35: Map<String, Object>...

org.apache.logging.log4j.LogManager; L19:import org.apache.logging.log4j.Logger; L20:import org.apache.lucene.search.BoostQuery; L21:import org.apache.lucene.search.Query; L22:import org.codelibs.fess.entity.QueryContext; L23:import org.codelibs.fess.exception.InvalidQueryException; L24:import org.lastaflute.core.message.UserMessages; L25:import org.opensearch.index.query.QueryBuilder; L26: L27:public class BoostQueryCommand extends QueryCommand { L28: private static final Logger logger = LogManage...

java.util.concurrent.Executor; L22:import java.util.concurrent.Future; L23:import junit.framework.TestCase; L24: L25:/** Test for {@link ListenableFuture}. */ L26:public class ListenableFutureTest extends TestCase { L27: public void testNoNewApis() throws Exception { L28: assertWithMessage( L29: "Do not add new methods to ListenableFuture. Its API needs to continue to match the" L30: + " version we released in a separate artifact com.google.guava:listenablefuture.") L31: ...

"AS IS" BASIS, L12: * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, L13: * either express or implied. See the License for the specific language L14: * governing permissions and limitations under the License. L15: */ L16:package org.codelibs.fess.exception; L17: L18:import jakarta.servlet.ServletException; L19: L20:public class ServletRuntimeException extends RuntimeException { L21: L22: private static final long serialVersionUID = 1L; L23: L24: public ServletRuntimeException(final ServletException...