Subversion Repositories SmartDukaan

Rev

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

Rev 122 Rev 1249
Line 10... Line 10...
10 
from thrift.server import TServer
 10 
from thrift.server import TServer
11 
from shop2020.model.v1.catalog.impl.InventoryServiceHandler import InventoryServiceHandler
 11 
from shop2020.model.v1.catalog.impl.InventoryServiceHandler import InventoryServiceHandler
12 
 
 12 
 
13 
 
 13 
 
14 
host_name = 'localhost'
 14 
host_name = 'localhost'
15 
port = '9001'
 15 
port = 9001
- 
 
 16 
dbname = 'catalog'
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('catalog_service_server_host')
 22 
        host_name = config_client.get_property('catalog_service_server_host')
22 
        port = config_client.get_property('catalog_service_server_port')
 23 
        port = config_client.get_property('catalog_service_server_port')
23 
    except:
 24 
    except:
24 
        #error while spawning the config server
 25 
        #error while spawning the config server
25 
        host_name = 'localhost'
 26 
        host_name = 'localhost'
26 
        port = '9001'
 27 
        port = 9001
27
28
28 
    handler = InventoryServiceHandler()
 29 
    handler = InventoryServiceHandler(dbname)
29 
    processor = InventoryService.Processor(handler)
 30 
    processor = InventoryService.Processor(handler)
30 
    transport = TSocket.TServerSocket(port)
 31 
    transport = TSocket.TServerSocket(port)
31 
    tfactory = TTransport.TFramedTransportFactory()
 32 
    tfactory = TTransport.TFramedTransportFactory()
32 
    pfactory = TBinaryProtocolFactory()
 33 
    pfactory = TBinaryProtocolFactory()
33 
    server = TServer.TThreadedServer(processor, transport, tfactory, pfactory)
 34 
    server = TServer.TThreadedServer(processor, transport, tfactory, pfactory)