Class NettyStreamFactory

java.lang.Object
com.mongodb.connection.netty.NettyStreamFactory
All Implemented Interfaces:
StreamFactory

public class NettyStreamFactory extends Object implements StreamFactory
A StreamFactory for Streams based on Netty 4.x.
Since:
3.0
  • Constructor Details

    • 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 Details

    • 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