messages -> {}); L87: body.crudMode = CrudMode.CREATE; L88: final DataConfig dataConfig = getDataConfig(body).map(entity -> { L89: try { L90: dataConfigService.store(entity); L91: } catch (final Exception e) { L92: logger.warn("Failed to process a request.", e); L93: throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e))); L94: } L95: return...

L85: public Long load(final String key) throws Exception { L86: try { L87: final Path path = Paths.get(LaServletContextUtil.getServletContext().getRealPath(key)); L88: if (Files.isRegularFile(path)) { L89: return Files.getLastModifiedTime(path).toMillis(); L90: } L91: } catch (final Exception e) { L92: logger.debug("Failed to access...

og4j.Logger; L61:import org.apache.logging.log4j.core.config.Configurator; L62:import org.codelibs.core.exception.IORuntimeException; L63:import org.codelibs.core.lang.StringUtil; L64:import org.codelibs.core.lang.ThreadUtil; L65:import org.codelibs.core.misc.Pair; L66:import org.codelibs.fess.Constants; L67:import org.codelibs.fess.crawler.util.CharUtil; L68:import org.codelibs.fess.exception.FessSystemException; L69:import org.codelibs.fess.mylasta.action.FessMessages; L70:import org.codelibs....

java.util.function.Consumer; L44:import java.util.stream.Collectors; L45: L46:import org.apache.commons.text.StringEscapeUtils; L47:import org.apache.logging.log4j.LogManager; L48:import org.apache.logging.log4j.Logger; L49:import org.codelibs.core.exception.IORuntimeException; L50:import org.codelibs.core.io.CopyUtil; L51:import org.codelibs.core.lang.StringUtil; L52:import org.codelibs.core.misc.Pair; L53:import org.codelibs.curl.CurlResponse; L54:import org.codelibs.fess.Constants; L55:import org...

zos.putNextEntry(entry); L184: try (CurlResponse response = ComponentUtil.getCurlHelper().get("/_" + v1 + "/" + v2).execute()) { L185: CopyUtil.copy(response.getContentAsStream(), zos); L186: } L187: } catch (final Exception e) { L188: logger.warn("Failed to access /_{}/{}", v1, v2, e); L189: } L190: } L191: L192: protected void writeFesenCat(final ZipOutputStream zos, final String id) { L193: Arrays.stream(CAT_NAMES).forEach(name -> {...

org.codelibs.fess.app.web.login.LoginAction; L24:import org.codelibs.fess.exception.SsoMessageException; L25:import org.codelibs.fess.sso.SsoManager; L26:import org.codelibs.fess.sso.SsoResponseType; L27:import org.codelibs.fess.util.ComponentUtil; L28:import org.dbflute.optional.OptionalThing; L29:import org.lastaflute.web.Execute; L30:import org.lastaflute.web.login.credential.LoginCredential; L31:import org.lastaflute.web.login.exception.LoginFailureException; L32:import org.lastaflute.web.response.ActionResponse;...

org.lastaflute.web.response.HtmlResponse; L44:import org.lastaflute.web.response.render.RenderData; L45:import org.lastaflute.web.ruts.process.ActionRuntime; L46:import org.lastaflute.web.validation.VaErrorHook; L47:import org.lastaflute.web.validation.exception.ValidationErrorException; L48: L49:import jakarta.annotation.Resource; L50: L51:/** L52: * @author nullpos L53: * @author ma2tani L54: */ L55:public class AdminDictMappingAction extends FessAdminAction { L56: L57: public static final String ROLE...

time, and Asserts that the future L71: * throws an {@code ExecutableException} and that the cause of the {@code ExecutableException} is L72: * {@code expectedCause}. L73: */ L74: public void assertException(Throwable expectedCause) throws Exception { L75: // Verify that the listener executed in a reasonable amount of time. L76: Assert.assertTrue(countDownLatch.await(1L, SECONDS)); L77: L78: try { L79: future.get(); L80: Assert.fail("This call was supposed to throw an ExecutionException");...

L38:@Tag("Slowish") L39:class TaskRunnerRealBackendTest { L40: private val log = LinkedBlockingDeque<String>() L41: L42: private val loggingUncaughtExceptionHandler = L43: UncaughtExceptionHandler { _, throwable -> L44: log.put("uncaught exception: $throwable") L45: } L46: L47: private val threadFactory = L48: ThreadFactory { runnable -> L49: Thread(runnable, "TaskRunnerRealBackendTest").apply { L50: isDaemon = true L51: uncaughtExceptionHandler = loggingUncaughtExceptionHandler...

tests for {@link CountingInputStream}. L28: * L29: * @author Chris Nokleberg L30: */ L31:public class CountingInputStreamTest extends IoTestCase { L32: private CountingInputStream counter; L33: L34: @Override L35: protected void setUp() throws Exception { L36: super.setUp(); L37: counter = new CountingInputStream(new ByteArrayInputStream(new byte[20])); L38: } L39: L40: public void testReadSingleByte() throws IOException { L41: assertEquals(0, counter.getCount()); L42: assertEquals(0,...