String>> envSupplier) { L1135: DirContextHolder holder = contextLocal.get(); L1136: if (holder != null) { L1137: holder.inc(); L1138: return holder; L1139: } L1140: final Hashtable<String, String> env = envSupplier.get(); L1141: try { L1142: holder = new DirContextHolder(new InitialDirContext(env)); L1143: contextLocal.set(holder); L1144: return holder; L1145: } catch (final NamingException e) { L1146:...

L20: L21:public abstract class CorsHandler { L22: L23: protected static final String ACCESS_CONTROL_ALLOW_ORIGIN = "Access-Control-Allow-Origin"; L24: L25: protected static final String ACCESS_CONTROL_ALLOW_HEADERS = "Access-Control-Allow-Headers"; L26: L27: protected static final String ACCESS_CONTROL_ALLOW_METHODS = "Access-Control-Allow-Methods"; L28: L29: protected static final String ACCESS_CONTROL_ALLOW_PRIVATE_NETWORK = "Access-Control-Allow-Private-Network"; L30: L31: protected...

!= null) { L85: result.getSearchFieldLogList().add(new Pair<>(e.getKey(), e.getValue().toString())); L86: } L87: }); L88: } L89: final Object headersObj = source.get("headers"); L90: if (headersObj instanceof Map) { L91: ((Map<String, ?>) headersObj).entrySet().stream().forEach(e -> { L92: if (e.getValue() instanceof String[]) { L93: final String[] values...

searchFieldMap); L135: final Map<String, List<String>> headerMap = headerList.stream() L136: .collect(Collectors.groupingBy(Pair::getFirst, Collectors.mapping(Pair::getSecond, Collectors.toList()))); L137: sourceMap.put("headers", headerMap); L138: sourceMap.put("documents", documentList); L139: return sourceMap; L140: } L141: L142: @Override L143: protected void addFieldToSource(final Map<String, Object> sourceMap, final String field, final Object...

/** The key of the configuration. e.g. */ L257: String API_JSON_RESPONSE_HEADERS = "api.json.response.headers"; L258: L259: /** The key of the configuration. e.g. false */ L260: String API_JSON_RESPONSE_EXCEPTION_INCLUDED = "api.json.response.exception.included"; L261: L262: /** The key of the configuration. e.g. */ L263: String API_GSA_RESPONSE_HEADERS = "api.gsa.response.headers"; L264: L265: /** The key of the configuration. e.g. false */ L266: String API_GSA_RESPONSE_EXCEPTION_INCLUDED...

List<String>> requestHeaderMap = entity.getRequestHeaderList().stream() L483: .collect(Collectors.groupingBy(Pair::getFirst, Collectors.mapping(Pair::getSecond, Collectors.toList()))); L484: appendJson("headers", requestHeaderMap, buf); L485: buf.append('}'); L486: buf.append('\n'); L487: try { L488: writer.write(buf.toString()); L489: } catch (final IOException...

entType); L151: checkBoundarySize(contentType, boundary); L152: return boundary; L153: } L154: }; L155: } L156: L157: // #for_now jflute to suppress CVE-2014-0050 even if commons-fileupload is older than safety version (2024/09/08) L158: // but if you use safety version, this extension is basically unneeded (or you can use it as double check) L159: protected void checkBoundarySize(final String contentType, final byte[] boundary) { L160:...

public void setMaxEsStatusRetry(final int maxEsStatusRetry) { L1860: this.maxEsStatusRetry = maxEsStatusRetry; L1861: } L1862: L1863: @Override L1864: public Client filterWithHeader(final Map<String, String> headers) { L1865: return client.filterWithHeader(headers); L1866: } L1867: L1868: @Override L1869: public <Request extends ActionRequest, Response extends ActionResponse> ActionFuture<Response> execute( L1870: final ActionType<Response> action, final Request...

String LABELS_storage_bucket_name = "{labels.storage_bucket_name}"; L3158: L3159: /** The key of the message: File */ L3160: public static final String LABELS_storage_file = "{labels.storage_file}"; L3161: L3162: /** The key of the message: Folder Name */ L3163: public static final String LABELS_storage_folder_name = "{labels.storage_folder_name}"; L3164: L3165: /** The key of the message: Download */ L3166: public static final String LABELS_storage_button_download = "{labels.stor...

"https://example.com/" + encodeUrl("#") + "/@@bar/index.html#fragment?foo=bar"; L76: exp = "index.html"; L77: assertEquals(exp, transformer.getFileName(url, Constants.UTF_8)); L78: L79: url = "http://example.com/" + encodeUrl("#") + "/@@folder/test.txt"; L80: exp = "test.txt"; L81: assertEquals(exp, transformer.getFileName(url, Constants.UTF_8)); L82: L83: url = "http://example.com/test%20+%2B.txt"; L84: exp = "test +.txt"; L85: assertEquals(exp, tra...