Subversion Repositories SmartDukaan

Rev

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

Rev 4646 Rev 4651
Line 27... Line 27...
27
27
28 
	public static String dbHost;
 28 
	public static String dbHost;
29
29
30 
	public static void main(String[] args){
 30 
	public static void main(String[] args){
31 
		try{
 31 
		try{
32 
			int port = 9012;
 - 
 
33 
			try {
 - 
 
34 
			    dbHost = "jdbc:mysql://" + ConfigClient.getClient().get(ConfigClientKeys.payments_service_db_hostname.toString()) + "/payment";
 - 
 
35 
			    String portNo = ConfigClient.getClient().get(ConfigClientKeys.payments_service_server_port.toString());
 - 
 
36 
			    port = Integer.parseInt(portNo);
 - 
 
37 
			}catch(Exception e){
 - 
 
38 
			    logger.warn("Unable to get port number from the Config server because of:", e);
 - 
 
39 
			}
 - 
 
40 
 
 - 
 
41 
			// Setting dbHost env property to make this value accessible in context.xml
- 
 
42 
			// while spring context creation.
 - 
 
43 
			System.setProperty("dbHost", dbHost);
 - 
 
44
- 
 
45
32
- 
 
 33 
		    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());
- 
 
 35 
		    int port = Integer.parseInt(portNo);
- 
 
 36
46 
	        handler = new PaymentServiceHandler();
 37 
	        handler = new PaymentServiceHandler();
47 
	        processor = new Processor<Iface>(handler);
 38 
	        processor = new Processor<Iface>(handler);
48 
 
 39 
 
49 
	        logger.info("DB Connection String is: " + dbHost);
 40 
	        logger.info("DB Connection String is: " + dbHost);
50 
	        org.apache.commons.dbcp.BasicDataSource ds = (org.apache.commons.dbcp.BasicDataSource)handler.context.getBean("dataSource");
 - 
 
51 
	        logger.info("URL read by data source before setting is: " + ds.getUrl());
 41 
	        logger.info("URL read by data source before setting is: " + handler.getDataSourceUrl());
52 
	        ds.setUrl(dbHost);
 42 
	        handler.setDataSourceUrl(dbHost);
53 
	        logger.info("URL read by data source after setting is: " + ds.getUrl());
 43 
	        logger.info("URL read by data source after setting is: " + handler.getDataSourceUrl());
54
44
55 
			TServerTransport serverTransport = new TServerSocket(port);
 45 
			TServerTransport serverTransport = new TServerSocket(port);
56 
			TTransportFactory tFactory = new TFramedTransport.Factory();
 46 
			TTransportFactory tFactory = new TFramedTransport.Factory();
57 
			TProtocolFactory pFactory = new TBinaryProtocol.Factory();
 47 
			TProtocolFactory pFactory = new TBinaryProtocol.Factory();
58
48
Line 63... Line 53...
63 
			TServer server = new TThreadPoolServer(serverParams);
 53 
			TServer server = new TThreadPoolServer(serverParams);
64
54
65 
			logger.info("Payment service started on port 9012");
 55 
			logger.info("Payment service started on port 9012");
66 
			server.serve();
 56 
			server.serve();
67 
		}catch(Exception ex){
 57 
		}catch(Exception ex){
68 
			ex.printStackTrace();
 58 
			logger.error("Unable to get port number from the Config server because of:", ex);
69 
		}
 59 
		}
70 
	}
 60 
	}
71 
}
 61 
}