org.apache.flink.runtime.io.network.netty

Class SSLHandlerFactory

java.lang.Object

org.apache.flink.runtime.io.network.netty.SSLHandlerFactory

public class SSLHandlerFactory
extends Object

Creates and configures SslHandler instances.

Constructor Summary

Constructors

Constructor and Description
SSLHandlerFactory(org.apache.flink.shaded.netty4.io.netty.handler.ssl.SslContext sslContext, int handshakeTimeoutMs, int closeNotifyFlushTimeoutMs) Create a new SslHandler factory.

Method Summary

Modifier and Type	Method and Description
org.apache.flink.shaded.netty4.io.netty.handler.ssl.SslHandler	createNettySSLHandler(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufAllocator allocator)
org.apache.flink.shaded.netty4.io.netty.handler.ssl.SslHandler	createNettySSLHandler(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufAllocator allocator, String hostname, int port)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SSLHandlerFactory

public SSLHandlerFactory(org.apache.flink.shaded.netty4.io.netty.handler.ssl.SslContext sslContext,
                         int handshakeTimeoutMs,
                         int closeNotifyFlushTimeoutMs)

Create a new SslHandler factory.

Parameters:

handshakeTimeoutMs - SSL session timeout during handshakes (-1 = use system default)

closeNotifyFlushTimeoutMs - SSL session timeout after flushing the close_notify message (-1 = use system default)

Method Detail

createNettySSLHandler

public org.apache.flink.shaded.netty4.io.netty.handler.ssl.SslHandler createNettySSLHandler(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufAllocator allocator)

createNettySSLHandler

public org.apache.flink.shaded.netty4.io.netty.handler.ssl.SslHandler createNettySSLHandler(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufAllocator allocator,
                                                                                            String hostname,
                                                                                            int port)