Subversion Repositories SmartDukaan

Rev

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

Rev 755 Rev 1248
Line 10... Line 10...
10 
from shop2020.logistics.service.impl.LogisticsServiceHandler import LogisticsServiceHandler
 10 
from shop2020.logistics.service.impl.LogisticsServiceHandler import LogisticsServiceHandler
11 
from shop2020.thriftpy.logistics import LogisticsService
 11 
from shop2020.thriftpy.logistics import LogisticsService
12 
 
 12 
 
13 
 
 13 
 
14 
host_name = 'localhost'
 14 
host_name = 'localhost'
15 
port = '9011'
 15 
port = 9011
- 
 
 16 
dbname='logistics'
16 
 
 17 
 
17 
def main():
 18 
def main():
18 
    #get the config client
 19 
    #get the config client
19 
    try:
 20 
    try:
20 
        config_client = ConfigClient()
 21 
        config_client = ConfigClient()
21 
        host_name = config_client.get_property('logistics_service_server_host')
 22 
        host_name = config_client.get_property('logistics_service_server_host')
22 
        port = config_client.get_property('logistics_service_server_port')
 23 
        port = int(config_client.get_property('logistics_service_server_port'))
23 
        pass
 24 
        pass
24 
    except:
 25 
    except:
25 
        #error while spawning the config server
 26 
        #error while spawning the config server
26 
        host_name = 'localhost'
 27 
        host_name = 'localhost'
27 
        port = '9011'
 28 
        port = 9011
28
29
29 
    handler = LogisticsServiceHandler()
 30 
    handler = LogisticsServiceHandler(dbname)
30 
    processor = LogisticsService.Processor(handler)
 31 
    processor = LogisticsService.Processor(handler)
31 
    transport = TSocket.TServerSocket(port)
 32 
    transport = TSocket.TServerSocket(port)
32 
    tfactory = TTransport.TFramedTransportFactory()
 33 
    tfactory = TTransport.TFramedTransportFactory()
33 
    pfactory = TBinaryProtocolFactory()
 34 
    pfactory = TBinaryProtocolFactory()
34 
    server = TServer.TThreadedServer(processor, transport, tfactory, pfactory)
 35 
    server = TServer.TThreadedServer(processor, transport, tfactory, pfactory)