NettyConnection extends TransportConnection { Map<ChannelOption, Object> getChannelOptions() { return channelOptions; } NettyConnection(
    final ConnectionConfig config,
    final Class<? extends Channel> type,
    final EventLoopGroup ioGroup,
    final EventLoopGroup messageGroup,
    final boolean shutdownGroups); @Override LdapURL getLdapURL(); @Override @SuppressWarnings("unchecked") BindResponse operation(final SaslClientRequest request); @Override @SuppressWarnings("unchecked") BindResponse operation(final DefaultSaslClientRequest request); @Override void operation(final AbandonRequest request); @Override DefaultOperationHandle<AddRequest, AddResponse> operation(final AddRequest request); @Override BindOperationHandle operation(final BindRequest request); @Override DefaultCompareOperationHandle operation(final CompareRequest request); @Override DefaultOperationHandle<DeleteRequest, DeleteResponse> operation(final DeleteRequest request); @Override DefaultExtendedOperationHandle operation(final ExtendedRequest request); @Override DefaultOperationHandle<ModifyRequest, ModifyResponse> operation(final ModifyRequest request); @Override DefaultOperationHandle<ModifyDnRequest, ModifyDnResponse> operation(final ModifyDnRequest request); @Override DefaultSearchOperationHandle operation(final SearchRequest request); @Override void close(final RequestControl... controls); boolean isOpen(); @Override String toString();  }
@Test(groups = "netty") public void transportOptions() throws Exception { final NettyConnection conn = new NettyConnection( ConnectionConfig.builder() .url("ldap: .transportOption("AUTO_READ", "false") .transportOption("TCP_NODELAY", true) .transportOption("SO_SNDBUF", "1024") .transportOption("SO_RCVBUF", 1024) .build(), NioSocketChannel.class, new NioEventLoopGroup( 0, new ThreadPerTaskExecutor(new DefaultThreadFactory(NettyConnectionTest.class, true, Thread.NORM_PRIORITY))), null, true); final Map<ChannelOption, Object> options = conn.getChannelOptions(); Assert.assertNotNull(options); Assert.assertEquals(options.get(ChannelOption.AUTO_READ), false); Assert.assertEquals(options.get(ChannelOption.TCP_NODELAY), true); Assert.assertEquals(options.get(ChannelOption.SO_SNDBUF), 1024); Assert.assertEquals(options.get(ChannelOption.SO_RCVBUF), 1024); }