String documentEndpoint, \r
Logger logger) {\r
\r
+ String deobfuscatedCertPassword = keystorePwd.startsWith("OBF:")?Password.deobfuscate(keystorePwd):keystorePwd;\r
// Create REST client for search service\r
searchClient = new RestClient()\r
.authenticationMode(RestAuthenticationMode.SSL_CERT)\r
.validateServerHostname(false)\r
- .validateServerCertChain(true)\r
+ .validateServerCertChain(false)\r
.clientCertFile(DataRouterConstants.DR_HOME_AUTH + certName)\r
- .clientCertPassword(Password.deobfuscate(keystorePwd))\r
- .trustStore(DataRouterConstants.DR_HOME_AUTH + keystore);\r
+ .clientCertPassword(deobfuscatedCertPassword); \r
\r
this.searchUrl = searchUrl;\r
this.documentEndpoint = documentEndpoint;\r
* Removes a document from the Search Service.\r
* \r
* @param index - The index to create the document in.\r
- * @param id - The identifier for the document.\r
- * @param payload - The document contents.\r
+ * @param documentId - The identifier for the document.\r
* @param headers - HTTP headers.\r
*/\r
public void deleteDocument(String index, String documentId, Map<String, List<String>> headers) {\r
*/\r
protected String loadFileData(String filename) throws Exception {\r
StringBuilder data = new StringBuilder();\r
- try {\r
- BufferedReader in = new BufferedReader(new InputStreamReader(\r
- EntityEventPolicy.class.getClassLoader().getResourceAsStream("/" + filename),\r
- StandardCharsets.UTF_8));\r
- String line;\r
\r
+ try (InputStreamReader inputStreamReader = new InputStreamReader(EntityEventPolicy.class.getClassLoader()\r
+ .getResourceAsStream("/" + filename), StandardCharsets.UTF_8); BufferedReader in = new BufferedReader(\r
+ inputStreamReader)\r
+ ) {\r
+\r
+ String line;\r
while ((line = in.readLine()) != null) {\r
data.append(line);\r
}\r