Best practice to overwrite ElasticSearchConnection class

[Steven Zhu]

Hi There,

I need to overwrite ElasticSearchConnection class to add SSL encrypted connection to Elasticsearch as the following:

if (needsHttps) {

try {

    FileInputStream fileInputStream = new FileInputStream(keystorePath);

    KeyStore truststore = KeyStore.getInstance("jks");

    truststore.load(fileInputStream, keystorePassword.toCharArray());

    SSLContextBuilder sslBuilder = SSLContexts.custom().loadTrustMaterial(truststore, null);

                                    SSLContext sslContext = sslBuilder.build();

                                    httpClientBuilder.setSSLContext(sslContext);

} catch  (NoSuchAlgorithmException | CertificateException | KeyManagementException | KeyStoreException e) {

_logger.error("Failed to instantiate sslcontext object: \n{}", e.getMessage());

throw new SecurityException();

} catch (IOException ioe) {

_logger.error("Failed to find keystore: \n{}", ioe.getMessage());

throw new RuntimeException();

}

    }

Thanks

Steven

[Julien Nioche]

Hi Steven

At the moment I am afraid you'd have to copy the whole elastic module of StormCrawler and modify that class. Other parts of the code rely on the current implementation explicitly and do not have a mechanism to specify an alternative implementation.
Feel free to open an issue on Github so that we add this functionality in a future release or allow a custom implementation of the connection class to be used.

Thanks

Julien

[Steven Zhu]

Hi Julien,

Thank you for the quick response. I have a bug to fix. Once I fix, I will create an issue and submit source codes with configuration changes for this functionality.

Steven