Class NettyStreamFactory

    • Constructor Detail

      • NettyStreamFactory

        public NettyStreamFactory​(SocketSettings settings,
                                  SslSettings sslSettings,
                                  io.netty.channel.EventLoopGroup eventLoopGroup,
                                  Class<? extends io.netty.channel.socket.SocketChannel> socketChannelClass,
                                  io.netty.buffer.ByteBufAllocator allocator,
                                  @Nullable
                                  io.netty.handler.ssl.SslContext sslContext)
        Construct a new instance of the factory.
        Parameters:
        settings - the socket settings
        sslSettings - the SSL settings
        eventLoopGroup - the event loop group that all channels created by this factory will be a part of
        socketChannelClass - the socket channel class
        allocator - the allocator to use for ByteBuf instances
        sslContext - the Netty SslContext as specified by NettyStreamFactoryFactory.Builder.sslContext(SslContext).
        Since:
        4.3
      • NettyStreamFactory

        public NettyStreamFactory​(SocketSettings settings,
                                  SslSettings sslSettings,
                                  io.netty.channel.EventLoopGroup eventLoopGroup,
                                  Class<? extends io.netty.channel.socket.SocketChannel> socketChannelClass,
                                  io.netty.buffer.ByteBufAllocator allocator)
        Construct a new instance of the factory.
        Parameters:
        settings - the socket settings
        sslSettings - the SSL settings
        eventLoopGroup - the event loop group that all channels created by this factory will be a part of
        socketChannelClass - the socket channel class
        allocator - the allocator to use for ByteBuf instances
        Since:
        3.3
      • NettyStreamFactory

        public NettyStreamFactory​(SocketSettings settings,
                                  SslSettings sslSettings,
                                  io.netty.channel.EventLoopGroup eventLoopGroup,
                                  io.netty.buffer.ByteBufAllocator allocator)
        Construct a new instance of the factory.
        Parameters:
        settings - the socket settings
        sslSettings - the SSL settings
        eventLoopGroup - the event loop group that all channels created by this factory will be a part of
        allocator - the allocator to use for ByteBuf instances
      • NettyStreamFactory

        public NettyStreamFactory​(SocketSettings settings,
                                  SslSettings sslSettings,
                                  io.netty.channel.EventLoopGroup eventLoopGroup)
        Construct a new instance of the factory.
        Parameters:
        settings - the socket settings
        sslSettings - the SSL settings
        eventLoopGroup - the event loop group that all channels created by this factory will be a part of
        Since:
        3.4
      • NettyStreamFactory

        public NettyStreamFactory​(SocketSettings settings,
                                  SslSettings sslSettings)
        Construct a new instance of the factory with a default allocator, nio event loop group and nio socket channel.
        Parameters:
        settings - the socket settings
        sslSettings - the SSL settings
    • Method Detail

      • create

        public Stream create​(ServerAddress serverAddress)
        Description copied from interface: StreamFactory
        Create a Stream to the given address
        Specified by:
        create in interface StreamFactory
        Parameters:
        serverAddress - the address
        Returns:
        the stream