L26:import org.apache.logging.log4j.LogManager; L27:import org.apache.logging.log4j.Logger; L28:import org.codelibs.core.lang.StringUtil; L29:import org.codelibs.core.timer.TimeoutTask; L30:import org.codelibs.fess.Constants; L31:import org.codelibs.fess.exception.JobProcessingException; L32:import org.codelibs.fess.exec.SuggestCreator; L33:import org.codelibs.fess.helper.ProcessHelper; L34:import org.codelibs.fess.mylasta.direction.FessConfig; L35:import org.codelibs.fess.util.ComponentUtil; L36:import o...

} L51: ResultData target = resultData; L52: for (final Ingester ingester : ingestFactory.getIngesters()) { L53: try { L54: target = ingester.process(target, responseData); L55: } catch (final Exception e) { L56: logger.warn("Failed to process Ingest[{}]", ingester.getClass().getSimpleName(), e); L57: } L58: } L59: return target; L60: } L61:}...

L34: assertTrue(content.length() > 0); L35: }, e -> { L36: logger.log(Level.SEVERE, "error", e); L37: fail(); L38: }); L39: } L40: L41: /* L42: @Test L43: public void test_Get_ssl() throws Exception { L44: final String filename = "config/certs/http_ca.crt"; L45: try (InputStream in = new FileInputStream(filename)) { L46: Certificate certificate = CertificateFactory.getInstance("X.509").generateCertificate(in); L47: L48:...

"Priority"}) L36: String queueType; L37: L38: @Param boolean useMonitor; L39: L40: private BlockingQueue<String> queue; L41: private String[] strings; L42: L43: @BeforeExperiment L44: @SuppressWarnings("unchecked") L45: void setUp() throws Exception { L46: String prefix = L47: (useMonitor ? "com.google.common.util.concurrent.MonitorBased" : "java.util.concurrent."); L48: String className = prefix + queueType + "BlockingQueue"; L49: Constructor<?> constructor = Class.forName(...

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 -> {...

ComponentUtil; L21: L22:import jcifs.SID; L23:import jcifs.smb.SmbException; L24: L25:public class SambaHelperTest extends UnitFessTestCase { L26: L27: public SambaHelper sambaHelper; L28: L29: @Override L30: public void setUp() throws Exception { L31: super.setUp(); L32: sambaHelper = new SambaHelper(); L33: } L34: L35: public void test_smb_account() throws SmbException { L36: ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() { L37: @Override...

order other than insertion order must override this method. L59: * L60: * <p>Note: This default implementation is overkill (but valid) for an unordered container. An L61: * equally valid implementation for an unordered container is to throw an exception. The chosen L62: * implementation, however, has the advantage of working for insertion-ordered containers, as L63: * well. L64: */ L65: @Override L66: public List<Integer> order(List<Integer> insertionOrder) { L67: return insertionOrder;...

L17: L18:import java.util.ArrayList; L19:import java.util.HashMap; L20:import java.util.List; L21:import java.util.Map; L22: L23:import org.codelibs.core.lang.StringUtil; L24:import org.codelibs.core.stream.StreamUtil; L25:import org.codelibs.fess.exception.InvalidQueryException; L26:import org.codelibs.fess.mylasta.direction.FessConfig; L27:import org.codelibs.fess.util.ComponentUtil; L28:import org.lastaflute.core.message.UserMessages; L29:import org.opensearch.index.query.BoolQueryBuilder; L30:import...

dSkipAll() throws Exception { L636: Collection<String> set = Sets.newLinkedHashSet(); L637: Collections.addAll(set, "a", "b", "c"); L638: FluentIterable<String> tail = FluentIterable.from(set).skip(2); L639: set.remove("a"); L640: set.remove("b"); L641: assertFalse(tail.iterator().hasNext()); L642: } L643: L644: public void testSkip_structurallyModifiedSkipAllList() throws Exception { L645: List<String> list = Lists.newArrayList("a", "b", "c"); L646: FluentIterable<String>...

* Tests for the {@link XmlEscapers} class. L28: * L29: * @author Alex Matevossian L30: * @author David Beaumont L31: */ L32:@GwtCompatible L33:public class XmlEscapersTest extends TestCase { L34: L35: public void testXmlContentEscaper() throws Exception { L36: CharEscaper xmlContentEscaper = (CharEscaper) XmlEscapers.xmlContentEscaper(); L37: assertBasicXmlEscaper(xmlContentEscaper, false, false); L38: // Test quotes are not escaped. L39: assertEquals("\"test\"", xmlContentEscaper.escape("\"test\""));...