bucket: {}", fessConfig.getStorageBucket()); L304: } catch (final Exception e1) { L305: logger.warn("Failed to create bucket: {}", fessConfig.getStorageBucket(), e1); L306: } L307: } else if (logger.isDebugEnabled()) { L308: logger.debug("Failed to access {}", fessConfig.getStorageEndpoint(), e); L309: } L310: } catch (final Exception e) { L311: if (logger.isDebugEnabled()) { L312: logger.debug("Failed...

L33: }; L34: L35: private final OkHttpClient client; L36: L37: public RewriteResponseCacheControl(File cacheDirectory) throws Exception { L38: Cache cache = new Cache(cacheDirectory, 1024 * 1024); L39: cache.evictAll(); L40: L41: client = new OkHttpClient.Builder() L42: .cache(cache) L43: .build(); L44: } L45: L46: public void run() throws Exception { L47: for (int i = 0; i < 5; i++) { L48: System.out.println(" Request: " + i); L49: L50: Request request = new...

listener.onOpen(this, response) L78: while (!canceled && reader.processNextEvent()) { L79: } L80: } L81: } catch (e: Exception) { L82: val exception = L83: when { L84: canceled -> IOException("canceled", e) L85: else -> e L86: } L87: listener.onFailure(this, exception, response) L88: return L89: } L90: if (canceled) { L91: listener.onFailure(this, IOException("canceled"), response) L92: ...

descriptions L479: // (e.g. "LockA -> LockB", "LockB -> LockC", ...) L480: // Checks that the exception.getMessage() matches a regex of the form: L481: // "LockA -> LockB \b.*\b LockB -> LockC \b.*\b LockC -> LockA" L482: private void checkMessage(IllegalStateException exception, String... expectedLockCycle) { L483: String regex = Joiner.on("\\b.*\\b").join(expectedLockCycle); L484: assertThat(exception).hasMessageThat().containsMatch(regex); L485: } L486:}...

descriptions L479: // (e.g. "LockA -> LockB", "LockB -> LockC", ...) L480: // Checks that the exception.getMessage() matches a regex of the form: L481: // "LockA -> LockB \b.*\b LockB -> LockC \b.*\b LockC -> LockA" L482: private void checkMessage(IllegalStateException exception, String... expectedLockCycle) { L483: String regex = Joiner.on("\\b.*\\b").join(expectedLockCycle); L484: assertThat(exception).hasMessageThat().containsMatch(regex); L485: } L486:}...

tus; L35:import org.codelibs.fess.app.web.api.admin.FessApiAdminAction; L36:import org.codelibs.fess.entity.SearchRenderData; L37:import org.codelibs.fess.es.client.SearchEngineClient; L38:import org.codelibs.fess.exception.InvalidQueryException; L39:import org.codelibs.fess.exception.ResultOffsetExceededException; L40:import org.codelibs.fess.helper.SearchHelper; L41:import org.codelibs.fess.util.ComponentUtil; L42:import org.lastaflute.web.Execute; L43:import org.lastaflute.web.response.JsonResponse;...

L258: new Function<Adder, Adder>() { L259: @Override L260: public Adder apply(Adder adder) { L261: return new FailsToPropagateException(adder); L262: } L263: }, L264: "add(", L265: "exception"); L266: } L267: L268: public void testNotInterfaceType() { L269: assertThrows( L270: IllegalArgumentException.class, L271: () -> L272: new ForwardingWrapperTester() L273: .testForwarding(String.class,...

org.codelibs.fess.es.config.exbhv.JobLogBhv; L29:import org.codelibs.fess.es.config.exbhv.ScheduledJobBhv; L30:import org.codelibs.fess.es.config.exentity.JobLog; L31:import org.codelibs.fess.es.config.exentity.ScheduledJob; L32:import org.codelibs.fess.exception.ScheduledJobException; L33:import org.codelibs.fess.mylasta.direction.FessConfig; L34:import org.codelibs.fess.util.ComponentUtil; L35:import org.dbflute.optional.OptionalThing; L36:import org.lastaflute.job.JobManager; L37:import org.lastaflute.job.LaCron;...

private final OkHttpClient client; L605: L606: public CacheResponse(File cacheDirectory) throws Exception { L607: int cacheSize = 10 * 1024 * 1024; // 10 MiB L608: Cache cache = new Cache(cacheDirectory, cacheSize); L609: L610: client = new OkHttpClient.Builder() L611: .cache(cache) L612: .build(); L613: } L614: L615: public void run() throws Exception { L616: Request request = new Request.Builder() L617: .url("http://publicobj...

public void run() { L153: numCalls.incrementAndGet(); L154: throw new RuntimeException("FAKE EXCEPTION!"); L155: } L156: }; L157: L158: e.execute(runMe); L159: e.execute(runMe); L160: fakePool.runAll(); L161: L162: assertEquals(2, numCalls.get()); L163: } L164: L165: public void testInterrupt_beforeRunRestoresInterruption() throws Exception { L166: // Run a task on the composed Executor that interrupts its thread (i.e. this thread). L167: fakePool.execute(...