limitations under the License. L15: */ L16:package org.codelibs.fess.test.net.protocol.xxx1; L17: L18:import java.io.IOException; L19:import java.net.URL; L20:import java.net.URLConnection; L21:import java.net.URLStreamHandler; L22: L23:public class Handler extends URLStreamHandler { L24: L25: public static final String PROTOCOL_TYPE = "web"; L26: L27: @Override L28: protected URLConnection openConnection(URL u) throws IOException { L29: return null; L30: } L31: L32:}...

limitations under the License. L15: */ L16:package org.codelibs.fess.test.net.protocol.xxx3; L17: L18:import java.io.IOException; L19:import java.net.URL; L20:import java.net.URLConnection; L21:import java.net.URLStreamHandler; L22: L23:public class Handler extends URLStreamHandler { L24: L25: public static final String PROTOCOL_TYPE = "test"; L26: L27: @Override L28: protected URLConnection openConnection(URL u) throws IOException { L29: return null; L30: } L31: L32:}...

limitations under the License. L15: */ L16:package org.codelibs.fess.test.net.protocol.xxx4; L17: L18:import java.io.IOException; L19:import java.net.URL; L20:import java.net.URLConnection; L21:import java.net.URLStreamHandler; L22: L23:public class Handler extends URLStreamHandler { L24: L25: @Override L26: protected URLConnection openConnection(URL u) throws IOException { L27: return null; L28: } L29: L30:}...

limitations under the License. L15: */ L16:package org.codelibs.fess.test.net.protocol.xxx2; L17: L18:import java.io.IOException; L19:import java.net.URL; L20:import java.net.URLConnection; L21:import java.net.URLStreamHandler; L22: L23:public class Handler extends URLStreamHandler { L24: L25: public static final String PROTOCOL_TYPE = "file"; L26: L27: @Override L28: protected URLConnection openConnection(URL u) throws IOException { L29: return null; L30: } L31: L32:}...

HashMap<>(); L28: L29: public void add(final String origin, final CorsHandler handler) { L30: if (logger.isDebugEnabled()) { L31: logger.debug("Loaded {}", origin); L32: } L33: handerMap.put(origin, handler); L34: } L35: L36: public CorsHandler get(final String origin) { L37: final CorsHandler handler = handerMap.get(origin); L38: if (handler != null) { L39: return handler; L40: } L41: return handerMap.get("*"); L42: } L43:}...

docMeta.seqNo(hit.getSeqNo()); L197: docMeta.primaryTerm(hit.getPrimaryTerm()); L198: handler.handle(entity); L199: }); L200: L201: return !handler.isBreakCursor(); L202: }); L203: } L204: L205: protected <RESULT extends ENTITY> void delegateSelectBulk(final ConditionBean cb, final EntityRowHandler<List<RESULT>> handler, L206: final Class<? extends RESULT> entityType) { L207: assertCBStateValid(cb); L208: as...

docMeta.seqNo(hit.getSeqNo()); L197: docMeta.primaryTerm(hit.getPrimaryTerm()); L198: handler.handle(entity); L199: }); L200: L201: return !handler.isBreakCursor(); L202: }); L203: } L204: L205: protected <RESULT extends ENTITY> void delegateSelectBulk(final ConditionBean cb, final EntityRowHandler<List<RESULT>> handler, L206: final Class<? extends RESULT> entityType) { L207: assertCBStateValid(cb); L208: as...

logger.debug("HTTP Request: {}", httpRequest.getMethod()); L49: } L50: final CorsHandlerFactory factory = ComponentUtil.getCorsHandlerFactory(); L51: final CorsHandler handler = factory.get(origin); L52: if (handler != null) { L53: handler.process(origin, request, response); L54: L55: if (OPTIONS.equals(httpRequest.getMethod())) { L56: final HttpServletResponse httpResponse = (HttpServletResponse) response;...

docMeta.seqNo(hit.getSeqNo()); L197: docMeta.primaryTerm(hit.getPrimaryTerm()); L198: handler.handle(entity); L199: }); L200: L201: return !handler.isBreakCursor(); L202: }); L203: } L204: L205: protected <RESULT extends ENTITY> void delegateSelectBulk(final ConditionBean cb, final EntityRowHandler<List<RESULT>> handler, L206: final Class<? extends RESULT> entityType) { L207: assertCBStateValid(cb); L208: as...

catch (final ClassNotFoundRuntimeException e) { L125: logger.debug("{}.{}.Handler does not exist.", basePackage, protocol, e); L126: } catch (final NoSuchFieldRuntimeException e) { L127: logger.debug("{}.{}.Handler does not contain PROTOCOL_TYPE.", basePackage, protocol, e); L128: } catch (final Exception e) { L129: logger.warn("Cannot load Handler from {}.{}", basePackage, protocol, e); L130: } L131: }); L132: }...