nt.SearchEngineClient; L37:import org.codelibs.fess.es.config.exentity.CrawlingConfig; L38:import org.codelibs.fess.es.config.exentity.CrawlingInfo; L39:import org.codelibs.fess.es.config.exentity.CrawlingInfoParam; L40:import org.codelibs.fess.exception.FessSystemException; L41:import org.codelibs.fess.mylasta.direction.FessConfig; L42:import org.codelibs.fess.util.ComponentUtil; L43:import org.opensearch.index.query.QueryBuilders; L44:import org.opensearch.search.aggregations.AggregationBuilders;...

getDuplicateHost(form).ifPresent(entity -> { L188: try { L189: duplicateHostService.store(entity); L190: saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL)); L191: } catch (final Exception e) { L192: logger.warn("Failed to process a request.", e); L193: throwValidationError(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)), L194: this::asEditHtml);...

try { L200: keyMatchService.store(entity); L201: saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL)); L202: ComponentUtil.getKeyMatchHelper().update(); L203: } catch (final Exception e) { L204: logger.warn("Failed to process a request.", e); L205: throwValidationError(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)), L206: this::asEditHtml);...

// clear url filter L488: urlFilterService.delete(sid); L489: } catch (final Exception e) { L490: logger.warn("Failed to delete UrlFilter for {}", sid, e); L491: } L492: L493: try { L494: // clear queue L495: urlQueueService.clearCache(); L496: urlQueueService.delete(sid); L497: } catch (final Exception e) { L498: logger.warn("Failed to delete UrlQueue for {}", sid, e); L499: } L500: L501:...

ALLOWS_NULL_KEY_QUERIES) L68: public void testRemove_nullKeyQueriesUnsupported() { L69: try { L70: assertFalse(getMap().remove(null, v3())); L71: } catch (NullPointerException tolerated) { L72: // since the operation would be a no-op, the exception is not required L73: } L74: expectUnchanged(); L75: } L76: L77: @MapFeature.Require(value = SUPPORTS_REMOVE, absent = ALLOWS_NULL_VALUE_QUERIES) L78: public void testRemove_nullValueQueriesUnsupported() { L79: try { L80: assertF...

org.codelibs.fess.crawler.entity.ResponseData; L55:import org.codelibs.fess.crawler.entity.ResultData; L56:import org.codelibs.fess.crawler.entity.UrlQueue; L57:import org.codelibs.fess.crawler.exception.ChildUrlsException; L58:import org.codelibs.fess.crawler.exception.CrawlerSystemException; L59:import org.codelibs.fess.crawler.exception.CrawlingAccessException; L60:import org.codelibs.fess.crawler.transformer.impl.XpathTransformer; L61:import org.codelibs.fess.crawler.util.CrawlingParameterUtil; L62:import org...

static Path root() { L92: return FS.getRootDirectories().iterator().next(); L93: } L94: L95: private Path tempDir; L96: L97: @Override L98: protected void setUp() throws Exception { L99: tempDir = Files.createTempDirectory("MoreFilesTest"); L100: } L101: L102: @Override L103: protected void tearDown() throws Exception { L104: if (tempDir != null) { L105: // delete tempDir and its contents L106: Files.walkFileTree( L107: tempDir, L108: new SimpleFileVisitor<Path>()...

extends TestCase { L48: L49: public void testAddAndRemove_concurrentHashMap() throws Exception { L50: testAddAndRemove(new ConcurrentHashMap<String, AtomicInteger>()); L51: } L52: L53: public void testAddAndRemove_concurrentSkipListMap() throws Exception { L54: testAddAndRemove(new ConcurrentSkipListMap<String, AtomicInteger>()); L55: } L56: L57: public void testAddAndRemove_mapMakerMap() throws Exception { L58: MapMaker mapMaker = new MapMaker(); L59: // force MapMaker to use its own...

a tiny bit more testing, see {@link FileBackedOutputStreamAndroidIncompatibleTest}. L38: * L39: * @author Chris Nokleberg L40: */ L41:public class FileBackedOutputStreamTest extends IoTestCase { L42: L43: L44: public void testThreshold() throws Exception { L45: testThreshold(0, 100, true, false); L46: testThreshold(10, 100, true, false); L47: testThreshold(100, 100, true, false); L48: testThreshold(1000, 100, true, false); L49: testThreshold(0, 100, false, false); L50: testThreshold(10,...

License for the specific language L14: * governing permissions and limitations under the License. L15: */ L16:package org.codelibs.fess.exception; L17: L18:public class ThumbnailGenerationException extends FessSystemException { L19: L20: private static final long serialVersionUID = 1L; L21: L22: public ThumbnailGenerationException(final String message, final Exception cause) { L23: super(message, cause); L24: } L25: L26: public ThumbnailGenerationException(final String message) { L27:...