import org.apache.thrift.server.THsHaServer;
import org.apache.thrift.server.TNonblockingServer;
import org.apache.thrift.server.TServer;
+import org.apache.thrift.server.THsHaServer.Args;
import org.apache.thrift.transport.TNonblockingServerSocket;
import org.apache.thrift.server.ServerTestBase.TestHandler;
if (hsha) {
// HsHa Server
- serverEngine = new THsHaServer(testProcessor, tServerSocket);
+ serverEngine = new THsHaServer(new Args(tServerSocket).processor(testProcessor));
} else {
// Nonblocking Server
- serverEngine = new TNonblockingServer(testProcessor, tServerSocket);
+ serverEngine = new TNonblockingServer(new Args(tServerSocket).processor(testProcessor));
}
// Run it
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocolFactory;
import org.apache.thrift.server.TServer;
+import org.apache.thrift.server.TServer.Args;
+import org.apache.thrift.server.TSimpleServer;
import org.apache.thrift.server.TThreadPoolServer;
import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.server.ServerTestBase.TestHandler;
TServer serverEngine;
// Simple Server
- // serverEngine = new TSimpleServer(testProcessor, tServerSocket);
+ serverEngine = new TSimpleServer(new Args(tServerSocket).processor(testProcessor));
// ThreadPool Server
- serverEngine = new TThreadPoolServer(testProcessor, tServerSocket, tProtocolFactory);
+ //serverEngine = new TThreadPoolServer(testProcessor, tServerSocket, tProtocolFactory);
// Run it
System.out.println("Starting the server on port " + port + "...");