Subversion Repositories SmartDukaan

Rev

Rev 4651 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 4651 Rev 4718
Line 10... Line 10...
10 
import org.apache.thrift.transport.TServerTransport;
 10 
import org.apache.thrift.transport.TServerTransport;
11 
import org.apache.thrift.transport.TTransportFactory;
 11 
import org.apache.thrift.transport.TTransportFactory;
12 
import org.slf4j.Logger;
 12 
import org.slf4j.Logger;
13 
import org.slf4j.LoggerFactory;
 13 
import org.slf4j.LoggerFactory;
14 
 
 14 
 
- 
 
 15 
import org.apache.commons.daemon.Daemon;
- 
 
 16 
import org.apache.commons.daemon.DaemonContext;
- 
 
 17 
 
15 
import in.shop2020.payment.service.handler.PaymentServiceHandler;
 18 
import in.shop2020.payment.service.handler.PaymentServiceHandler;
16 
import in.shop2020.payments.PaymentService.Iface;
 19 
import in.shop2020.payments.PaymentService.Iface;
17 
import in.shop2020.payments.PaymentService.Processor;
 20 
import in.shop2020.payments.PaymentService.Processor;
18 
import in.shop2020.thrift.clients.config.ConfigClient;
 21 
import in.shop2020.thrift.clients.config.ConfigClient;
19 
import in.shop2020.utils.ConfigClientKeys;
 22 
import in.shop2020.utils.ConfigClientKeys;
20 
 
 23 
 
21 
public class PaymentServer {
 24 
public class PaymentServer implements Daemon {
22 
	private static Logger logger = LoggerFactory.getLogger(PaymentServer.class);
 25 
	private static Logger logger = LoggerFactory.getLogger(PaymentServer.class);
23
26
24 
	private static PaymentServiceHandler handler;
 27 
	private static PaymentServiceHandler handler;
25
28
26 
	private static Processor<Iface> processor;
 29 
	private static Processor<Iface> processor;
27
30
28 
	public static String dbHost;
 31 
	public static String dbHost;
29
32
- 
 
 33 
	private static TServer server;
- 
 
 34
30 
	public static void main(String[] args){
 35 
	public static void main(String[] args) {
- 
 
 36 
	    initialize();
- 
 
 37 
	}
- 
 
 38
- 
 
 39 
	private static void initialize() {
31 
		try{
 40 
		try{
32
41
33 
		    dbHost = "jdbc:mysql://" + ConfigClient.getClient().get(ConfigClientKeys.payments_service_db_hostname.toString()) + "/payment";
 42 
		    dbHost = "jdbc:mysql://" + ConfigClient.getClient().get(ConfigClientKeys.payments_service_db_hostname.toString()) + "/payment";
34 
		    String portNo = ConfigClient.getClient().get(ConfigClientKeys.payments_service_server_port.toString());
 43 
		    String portNo = ConfigClient.getClient().get(ConfigClientKeys.payments_service_server_port.toString());
35 
		    int port = Integer.parseInt(portNo);
 44 
		    int port = Integer.parseInt(portNo);
Line 48... Line 57...
48
57
49 
			Args serverParams = new Args(serverTransport);
 58 
			Args serverParams = new Args(serverTransport);
50 
			serverParams.processor(processor);
 59 
			serverParams.processor(processor);
51 
			serverParams.transportFactory(tFactory);
 60 
			serverParams.transportFactory(tFactory);
52 
			serverParams.protocolFactory(pFactory);
 61 
			serverParams.protocolFactory(pFactory);
53 
			TServer server = new TThreadPoolServer(serverParams);
 62 
			server = new TThreadPoolServer(serverParams);
54
63
55 
			logger.info("Payment service started on port 9012");
 64 
			logger.info("Payment service started on port 9012");
56 
			server.serve();
 65 
			server.serve();
57 
		}catch(Exception ex){
 66 
		}catch(Exception ex){
58 
			logger.error("Unable to get port number from the Config server because of:", ex);
 67 
			logger.error("Unable to get port number from the Config server because of:", ex);
59 
		}
 68 
		}
60 
	}
 69 
	}
- 
 
 70 
 
- 
 
 71 
    public void destroy() {
- 
 
 72 
        System.out.println("Payment Server stopped.");
- 
 
 73 
        // TODO Auto-generated method stub
- 
 
 74
- 
 
 75 
    }
- 
 
 76 
 
- 
 
 77 
    public void init(DaemonContext dc) throws Exception {
- 
 
 78 
        System.out.println("Initializing Payment Server...");
- 
 
 79 
        // TODO Auto-generated method stub
- 
 
 80
- 
 
 81 
    }
- 
 
 82 
 
- 
 
 83 
    public void start() throws Exception {
- 
 
 84 
        System.out.println("Starting Payment Server");
- 
 
 85 
        initialize();
- 
 
 86 
        // TODO Auto-generated method stub
- 
 
 87
- 
 
 88 
    }
- 
 
 89 
 
- 
 
 90 
    public void stop() throws Exception {
- 
 
 91 
        System.out.println("Stopping Payment Server...");
- 
 
 92 
        server.stop();
- 
 
 93 
        System.exit(0);
- 
 
 94 
        // TODO Auto-generated method stub
- 
 
 95
- 
 
 96 
    }
61 
}
 97 
}