Class SocketFrameHandlerFactory

    • Field Detail

      • socketFactory

        private final javax.net.SocketFactory socketFactory
      • shutdownExecutor

        private final java.util.concurrent.ExecutorService shutdownExecutor
    • Constructor Detail

      • SocketFrameHandlerFactory

        public SocketFrameHandlerFactory​(int connectionTimeout,
                                         javax.net.SocketFactory socketFactory,
                                         SocketConfigurator configurator,
                                         boolean ssl)
      • SocketFrameHandlerFactory

        public SocketFrameHandlerFactory​(int connectionTimeout,
                                         javax.net.SocketFactory socketFactory,
                                         SocketConfigurator configurator,
                                         boolean ssl,
                                         java.util.concurrent.ExecutorService shutdownExecutor)
      • SocketFrameHandlerFactory

        public SocketFrameHandlerFactory​(int connectionTimeout,
                                         javax.net.SocketFactory socketFactory,
                                         SocketConfigurator configurator,
                                         boolean ssl,
                                         java.util.concurrent.ExecutorService shutdownExecutor,
                                         SslContextFactory sslContextFactory,
                                         int maxInboundMessageBodySize)
    • Method Detail

      • create

        public FrameHandler create​(Address addr,
                                   java.lang.String connectionName)
                            throws java.io.IOException
        Throws:
        java.io.IOException
      • createSocket

        protected java.net.Socket createSocket​(java.lang.String connectionName)
                                        throws java.io.IOException
        Throws:
        java.io.IOException
      • create

        public FrameHandler create​(java.net.Socket sock)
                            throws java.io.IOException
        Throws:
        java.io.IOException
      • quietTrySocketClose

        private static void quietTrySocketClose​(java.net.Socket socket)