@Override
    protected SocketChannel newHandle(SocketAddress localAddress)
            throws Exception {
        SocketChannel ch = SocketChannel.open();

        int receiveBufferSize =
            (getSessionConfig()).getReceiveBufferSize();
        if (receiveBufferSize > 65535) {
            if (AbstractIoSessionConfig.ENABLE_BUFFER_SIZE) {
                System.out.println("NioSocketConnector.newHandle(" + receiveBufferSize + ")");
                ch.socket().setReceiveBufferSize(receiveBufferSize);
            }
        }

        if (localAddress != null) {
            ch.socket().bind(localAddress);
        }
        ch.configureBlocking(false);
        return ch;
    }
@ Override protected SocketChannel newHandle ( SocketAddress localAddress ) throws Exception { SocketChannel ch = SocketChannel . open ( ) ; int receiveBufferSize = ( getSessionConfig ( ) ) . getReceiveBufferSize ( ) ; if ( receiveBufferSize > 65535 ) { if ( AbstractIoSessionConfig . ENABLE_BUFFER_SIZE ) { System . out . println ( "NioSocketConnector.newHandle(" + receiveBufferSize + ")" ) ; ch . socket ( ) . setReceiveBufferSize ( receiveBufferSize ) ; } } if ( localAddress != null ) { ch . socket ( ) . bind ( localAddress ) ; } ch . configureBlocking ( false ) ; return ch ; }
{@inheritDoc}