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();

	}

}