Subversion Repositories SmartDukaan

package in.shop2020.googleadwords.service;

import in.shop2020.googleadwords.GoogleAdwordsService.Iface;
import in.shop2020.googleadwords.GoogleAdwordsService.Processor;
import in.shop2020.googleadwords.service.handler.AdwordsServiceHandler;
import in.shop2020.thrift.clients.config.ConfigClient;
import in.shop2020.utils.ConfigClientKeys;

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;

public class AdwordsServer implements Daemon {
        
        private static Logger logger = LoggerFactory.getLogger(AdwordsServer.class);
        
        private static AdwordsServiceHandler handler;
        
        private static Processor<Iface>       processor;
    
    private static TServer server;
    
    public static String dbHost;
        
    public static void main(String[] args) {
        initialize();
    }
    
    private static void initialize() {
        try {
                
                dbHost = "jdbc:mysql://" + ConfigClient.getClient().get(ConfigClientKeys.adwords_service_db_hostname.toString()) + "/catalog";
            handler = new AdwordsServiceHandler();
                        processor = new Processor<Iface>(handler);
            int port = 9229;
            try {
                String portNo = ConfigClient.getClient().get(
                        ConfigClientKeys.adwords_service_server_port
                                .toString());
                port = Integer.parseInt(portNo);
            } catch (Exception e) {
                logger.warn(
                        "Unable to get port number from the Config server because of:",
                        e);
            }
            
            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("Adwords service started on port 9229");
            server.serve();
        } catch (Exception ex) {
            logger.error("Error starting server", ex);
        }
    }
        
        public void destroy() {
                System.out.println("AdwordsServer stopped.");
        }

        public void init(DaemonContext arg0) throws Exception {
                System.out.println("Initializing AdwordsServer...");
        }

        public void start() throws Exception {
                System.out.println("Starting Adwords"); 
                initialize();
        }

        public void stop() throws Exception {
                System.out.println("Stopping CRMServer...");
        server.stop();
        System.exit(0);
        }
        
}