Subversion Repositories SmartDukaan

package in.shop2020.test;

import in.shop2020.test.TestService.Iface;
import in.shop2020.test.TestService.Processor;

import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocolFactory;
import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TThreadPoolServer;
import org.apache.thrift.server.TThreadPoolServer.Args;
import org.apache.thrift.transport.TFramedTransport;
import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.transport.TServerTransport;
import org.apache.thrift.transport.TTransportException;
import org.apache.thrift.transport.TTransportFactory;


public class TestServer {
        private String port = null;
        
        public TestServer(){
                        port = "9000";
        }
        
        public void startServer(){
                try {
                        
                        TServerTransport t1 = new TServerSocket(Integer.parseInt(port));
                        TTransportFactory tFactory = new TFramedTransport.Factory();
                        TProtocolFactory pFactory = new TBinaryProtocol.Factory();
                        
                        Processor<Iface> p = new Processor<TestService.Iface>(new TestHandler());
                        
                        System.out.println("Starting server at port 9000");
                        
                        Args args = new Args(t1);
                        args.processor(p);
                        args.transportFactory(tFactory);
                        args.protocolFactory(pFactory);
                        TServer server = new TThreadPoolServer(args);
                                              
        //              TServer server = new TThreadPoolServer(p, t, new TFramedTransport.Factory(), new TBinaryProtocol.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();
        }

}