Subversion Repositories SmartDukaan

package in.shop2020.test;

import in.shop2020.test.TestService.Processor;

import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TCompactProtocol;
import org.apache.thrift.protocol.TBinaryProtocol.Factory;
import org.apache.thrift.server.THsHaServer;
import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TSimpleServer;
import org.apache.thrift.server.TThreadPoolServer;
import org.apache.thrift.server.TThreadPoolServer.Options;
import org.apache.thrift.transport.TFramedTransport;
import org.apache.thrift.transport.TNonblockingServerSocket;
import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.transport.TServerTransport;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TTransportException;
import org.apache.thrift.transport.TTransportFactory;


public class TestServer {
        private String port = null;
        
        public TestServer(){
                        port = "9009";
        }
        
        public void startServer(){
                try {
                        //TServerSocket socket = new TServerSocket(Integer.parseInt(port));
                        Processor p = new Processor(new TestHandler());
                        TServerSocket t = new TServerSocket(Integer.parseInt(port));
                        
                        //TNonblockingServerSocket socket = new TNonblockingServerSocket(Integer.parseInt(port));
                        //TServerTransport t = new TServerSocket(Integer.parseInt(port));
                        //Factory protFactory = new TBinaryProtocol.Factory();
                        System.out.println("Starting server at port 9009");
                        TServer server = new TThreadPoolServer(p, t, new TFramedTransport.Factory(), new TBinaryProtocol.Factory());
                        //TServer server = new TThreadPoolServer(processor, serverTransport, inputTransportFactory, outputTransportFactory, inputProtocolFactory, outputProtocolFactory, options)
                        //TServer server = new THsHaServer(p,socket, new TFramedTransport.Factory(), new TCompactProtocol.Factory());
                        server.serve();
                } catch (NumberFormatException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                } catch (TTransportException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
        }
        
        public static void main(String[] args){
                TestServer server = new TestServer();
                server.startServer();
        }

}