com.mongodb.connection.netty

Class NettyStreamFactory

java.lang.Object

com.mongodb.connection.netty.NettyStreamFactory

All Implemented Interfaces:

StreamFactory

public class NettyStreamFactory
extends java.lang.Object
implements StreamFactory

A StreamFactory for Streams based on Netty 4.x.

Since:

3.0

Constructor Summary

Constructors

Constructor and Description
NettyStreamFactory(SocketSettings settings, SslSettings sslSettings) Construct a new instance of the factory with a default allocator, nio event loop group and nio socket channel.
NettyStreamFactory(SocketSettings settings, SslSettings sslSettings, io.netty.channel.EventLoopGroup eventLoopGroup) Construct a new instance of the factory.
NettyStreamFactory(SocketSettings settings, SslSettings sslSettings, io.netty.channel.EventLoopGroup eventLoopGroup, io.netty.buffer.ByteBufAllocator allocator) Construct a new instance of the factory.
NettyStreamFactory(SocketSettings settings, SslSettings sslSettings, io.netty.channel.EventLoopGroup eventLoopGroup, java.lang.Class<? extends io.netty.channel.socket.SocketChannel> socketChannelClass, io.netty.buffer.ByteBufAllocator allocator) Construct a new instance of the factory.

Method Summary

Modifier and Type	Method and Description
Stream	create(ServerAddress serverAddress) Create a Stream to the given address

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyStreamFactory

public NettyStreamFactory(SocketSettings settings,
                          SslSettings sslSettings,
                          io.netty.channel.EventLoopGroup eventLoopGroup,
                          java.lang.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