com.mongodb.connection.netty

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.0

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, io.netty.buffer.ByteBufAllocator allocator) Construct a new instance of the factory.
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.

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

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

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)

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)

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