+
+ @Override
+ public void onSslConnectionError(SslConnectionError notification) {
+ IpAddress ip = null;
+ if ((connectionContext.getConnectionAdapter() != null)
+ && (connectionContext.getConnectionAdapter().getRemoteAddress() != null)
+ && (connectionContext.getConnectionAdapter().getRemoteAddress().getAddress() != null)) {
+ ip = IpAddressBuilder.getDefaultInstance(
+ connectionContext.getConnectionAdapter().getRemoteAddress().getAddress().getHostAddress());
+ }
+ notificationPublishService
+ .offerNotification(
+ new SslErrorBuilder().setType(SslErrorType.SslConFailed)
+ .setCode(SslErrorType.SslConFailed.getIntValue())
+ .setNodeIpAddress(ip)
+ .setData(notification.getInfo())
+ .build());
+ }