Subversion Repositories SmartDukaan

package in.shop2020.user.service;

import org.apache.commons.daemon.Daemon;
import org.apache.commons.daemon.DaemonContext;
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.TTransportFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import in.shop2020.model.v1.user.UserContextService.Iface;
import in.shop2020.model.v1.user.UserContextService.Processor;
import in.shop2020.thrift.clients.config.ConfigClient;
import in.shop2020.user.handler.UserServiceHandler;
import in.shop2020.utils.ConfigClientKeys;

public class UserServer implements Daemon{

        private static Logger logger = LoggerFactory.getLogger(UserServer.class);
        private static UserServiceHandler handler;
        private static Processor<Iface> processor;
        public static String dbHost;
        private static TServer server;
        
        public static void main(String[] args) {
            initialize();
        }
        
        private static void initialize() {
                try{
                        
                    dbHost = "jdbc:mysql://" + ConfigClient.getClient().get(ConfigClientKeys.payments_service_db_hostname.toString()) + "/user";
                    String portNo = ConfigClient.getClient().get(ConfigClientKeys.user_service_server_port.toString());
                    int port = Integer.parseInt(portNo);
                    
                handler = new UserServiceHandler();
                processor = new Processor<Iface>(handler);

                logger.info("DB Connection String is: " + dbHost);
                logger.info("URL read by data source before setting is: " + handler.getDataSourceUrl());
                handler.setDataSourceUrl(dbHost);
                logger.info("URL read by data source after setting is: " + handler.getDataSourceUrl());
                
                        TServerTransport serverTransport = new TServerSocket(port);
                        TTransportFactory tFactory = new TFramedTransport.Factory();
                        TProtocolFactory pFactory = new TBinaryProtocol.Factory();
                        
                        Args serverParams = new Args(serverTransport);
                        serverParams.processor(processor);
                        serverParams.transportFactory(tFactory);
                        serverParams.protocolFactory(pFactory);
                        server = new TThreadPoolServer(serverParams);
                        
                        logger.info("User service started on port 9000");
                        server.serve();
                }catch(Exception ex){
                        logger.error("Unable to get port number from the Config server because of:", ex);
                }
        }


        public void destroy() {
        logger.info("User Server stopped.");
    }

    public void init(DaemonContext dc) throws Exception {
        logger.info("Initializing User Server...");
    }

    public void start() throws Exception {
        logger.info("Starting User Server");
        initialize();
    }

    public void stop() throws Exception {
        logger.info("Stopping User Server...");
        server.stop();
        System.exit(0);
    }

        
        
}