Subversion Repositories SmartDukaan

Rev

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

Rev 3024 Rev 3428
Line 1... Line 1...
1 
/**
 1 
/**
2 
 *
2 
 *
3 
 */
 3 
 */
4 
package in.shop2020.crm.service;
 4 
package in.shop2020.crm.service;
5 
 
 5 
 
- 
 
 6 
import in.shop2020.crm.CRMService.Iface;
6 
import in.shop2020.crm.CRMService.Processor;
 7 
import in.shop2020.crm.CRMService.Processor;
7 
import in.shop2020.crm.service.handler.CRMServiceHandler;
 8 
import in.shop2020.crm.service.handler.CRMServiceHandler;
8 
import in.shop2020.thrift.clients.config.ConfigClient;
 9 
import in.shop2020.thrift.clients.config.ConfigClient;
9 
import in.shop2020.utils.ConfigClientKeys;
 10 
import in.shop2020.utils.ConfigClientKeys;
10 
 
 11 
 
11 
import org.apache.thrift.protocol.TBinaryProtocol;
 12 
import org.apache.thrift.protocol.TBinaryProtocol;
12 
import org.apache.thrift.protocol.TProtocolFactory;
 13 
import org.apache.thrift.protocol.TProtocolFactory;
13 
import org.apache.thrift.server.TServer;
 14 
import org.apache.thrift.server.TServer;
14 
import org.apache.thrift.server.TThreadPoolServer;
 15 
import org.apache.thrift.server.TThreadPoolServer;
- 
 
 16 
import org.apache.thrift.server.TThreadPoolServer.Args;
15 
import org.apache.thrift.transport.TFramedTransport;
 17 
import org.apache.thrift.transport.TFramedTransport;
16 
import org.apache.thrift.transport.TServerSocket;
 18 
import org.apache.thrift.transport.TServerSocket;
17 
import org.apache.thrift.transport.TServerTransport;
 19 
import org.apache.thrift.transport.TServerTransport;
18 
import org.apache.thrift.transport.TTransportFactory;
 20 
import org.apache.thrift.transport.TTransportFactory;
19 
import org.slf4j.Logger;
 21 
import org.slf4j.Logger;
Line 28... Line 30...
28 
public class CRMServer {
 30 
public class CRMServer {
29 
    private static Logger            logger = LoggerFactory.getLogger(CRMServer.class);
 31 
    private static Logger            logger = LoggerFactory.getLogger(CRMServer.class);
30 
 
 32 
 
31 
    private static CRMServiceHandler handler;
 33 
    private static CRMServiceHandler handler;
32 
 
 34 
 
33 
    private static Processor         processor;
 35 
    private static Processor<Iface>       processor;
34 
 
 36 
 
35 
    public static void main(String[] args) {
 37 
    public static void main(String[] args) {
36 
        try {
 38 
        try {
37 
            handler = new CRMServiceHandler();
 39 
            handler = new CRMServiceHandler();
38 
            processor = new Processor(handler);
 40 
			processor = new Processor<Iface>(handler);
39 
 
 - 
 
40 
            int port = 9014;
 41 
            int port = 9014;
41 
            try {
 42 
            try {
42 
                String portNo = ConfigClient.getClient().get(
 43 
                String portNo = ConfigClient.getClient().get(
43 
                        ConfigClientKeys.crm_service_server_port
 44 
                        ConfigClientKeys.crm_service_server_port
44 
                                .toString());
 45 
                                .toString());
Line 50... Line 51...
50 
            }
 51 
            }
51 
 
 52 
 
52 
            TServerTransport serverTransport = new TServerSocket(port);
 53 
            TServerTransport serverTransport = new TServerSocket(port);
53 
            TTransportFactory tFactory = new TFramedTransport.Factory();
 54 
            TTransportFactory tFactory = new TFramedTransport.Factory();
54 
            TProtocolFactory pFactory = new TBinaryProtocol.Factory();
 55 
            TProtocolFactory pFactory = new TBinaryProtocol.Factory();
- 
 
 56
55 
            TServer server = new TThreadPoolServer(processor, serverTransport,
 57 
        	Args serverParams = new Args(serverTransport);
- 
 
 58 
			serverParams.processor(processor);
- 
 
 59 
			serverParams.transportFactory(tFactory);
56 
                    tFactory, pFactory);
 60 
			serverParams.protocolFactory(pFactory);
- 
 
 61
- 
 
 62 
			TServer server = new TThreadPoolServer(serverParams);
57 
 
 63 
 
58 
            logger.info("CRM service started on port 9014");
 64 
            logger.info("CRM service started on port 9014");
59 
            server.serve();
 65 
            server.serve();
60 
        } catch (Exception ex) {
 66 
        } catch (Exception ex) {
61 
            ex.printStackTrace();
 67 
            ex.printStackTrace();