TServerTransport serverTransport = new TServerSocket(port); TThreadPoolServer.Args a = new TThreadPoolServer.Args(serverTransport).processor(processor); a.maxWorkerThreads(5); TThreadPoolServer server = new TThreadPoolServer(a); return server;