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 11... Line 11...
11 
from shop2020.helpers.impl.HelperServiceHandler import HelperServiceHandler
 11 
from shop2020.helpers.impl.HelperServiceHandler import HelperServiceHandler
12 
from shop2020.thriftpy.utils import HelperService
 12 
from shop2020.thriftpy.utils import HelperService
13 
 
 13 
 
14 
 
 14 
 
15 
host_name = 'localhost'
 15 
host_name = 'localhost'
16 
port = '9008'
 16 
port = 9008
- 
 
 17 
dbname = 'helper'
17 
 
 18 
 
18 
def main():
 19 
def main():
19 
    #get the config client
 20 
    #get the config client
20 
    try:
 21 
    try:
21 
        config_client = ConfigClient()
 22 
        config_client = ConfigClient()
22 
        host_name = config_client.get_property('helper_service_server_host')
 23 
        host_name = config_client.get_property('helper_service_server_host')
23 
        port = config_client.get_property('helper_service_server_port')
 24 
        port = int(config_client.get_property('helper_service_server_port'))
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 = '9008'
 28 
        port = 9008
28
29
29 
    handler = HelperServiceHandler()
 30 
    handler = HelperServiceHandler(dbname)
30 
    processor = HelperService.Processor(handler)
 31 
    processor = HelperService.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)