summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
6b1777b)
Change-Id: I8d4459c4b612e6066ae0da9521333fc3083952d3
Issue-ID: DCAEGEN2-760
Signed-off-by: Filip Krzywka <filip.krzywka@nokia.com>
*/
package org.onap.dcae.collectors.veshv.simulators.xnf.impl.adapters
*/
package org.onap.dcae.collectors.veshv.simulators.xnf.impl.adapters
+import arrow.core.Option
import io.netty.handler.ssl.ClientAuth
import io.netty.handler.ssl.SslContext
import io.netty.handler.ssl.SslContextBuilder
import io.netty.handler.ssl.ClientAuth
import io.netty.handler.ssl.SslContext
import io.netty.handler.ssl.SslContextBuilder
.options { opts ->
opts.host(configuration.vesHost)
.port(configuration.vesPort)
.options { opts ->
opts.host(configuration.vesHost)
.port(configuration.vesPort)
- .sslContext(createSslContext(configuration.security))
+ .sslContext(createSslContext(configuration.security).orNull())
- private fun createSslContext(config: SecurityConfiguration): SslContext =
- SslContextBuilder.forClient()
- .keyManager(config.cert.toFile(), config.privateKey.toFile())
- .trustManager(config.trustedCert.toFile())
- .sslProvider(SslProvider.OPENSSL)
- .clientAuth(ClientAuth.REQUIRE)
- .build()
+ private fun createSslContext(config: SecurityConfiguration): Option<SslContext> =
+ if (config.sslDisable) {
+ Option.empty()
+ } else {
+ Option.just(
+ SslContextBuilder.forClient()
+ .keyManager(config.cert.toFile(), config.privateKey.toFile())
+ .trustManager(config.trustedCert.toFile())
+ .sslProvider(SslProvider.OPENSSL)
+ .clientAuth(ClientAuth.REQUIRE)
+ .build()
+ )
+ }
private fun NettyOutbound.logConnectionClosed(): NettyOutbound {
context().onClose {
private fun NettyOutbound.logConnectionClosed(): NettyOutbound {
context().onClose {