code: public static TServer createNonBlockingServer(TProcessorFactory processorFactory,
              TProtocolFactory protocolFactory, int port, int clientTimeoutMillisecs,
              int maxFrameSize, long maxReadBufferSize) throws TTransportException {
          TNonblockingServerTransport transport = new TNonblockingServerSocket(port,
                  clientTimeoutMillisecs);
          TTransportFactory transportFactory = new TFramedTransport.Factory(maxFrameSize);
          TNonblockingServer.Args args = new TNonblockingServer.Args(transport)
                  .processorFactory(processorFactory).protocolFactory(protocolFactory)
                  .transportFactory(transportFactory);
          args.maxReadBufferBytes = maxReadBufferSize;
          TNonblockingServer server = new TNonblockingServer(args);
          return server;
      }
docs: Helper method to create a new framed-transport, non-blocking
  {@link TServer}.
  
  @param processorFactory
  @param protocolFactory
  @param port
  @param clientTimeoutMillisecs
  @param maxFrameSize
  @param maxReadBufferSize
  @return
  @throws TTransportException