Subversion Repositories SmartDukaan

Rev

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

Rev 1277 Rev 3187
Line 11... Line 11...
11
from shop2020.config.client.ConfigClient import ConfigClient
11
from shop2020.config.client.ConfigClient import ConfigClient
12
 
12
 
13
host_name = 'localhost'
13
host_name = 'localhost'
14
port = 9002
14
port = 9002
15
dbname = 'transaction'
15
dbname = 'transaction'
-
 
16
db_hostname='localhost'
16
 
17
 
17
def main():
18
def main():
18
    try:
19
    try:
19
        config_client = ConfigClient()
20
        config_client = ConfigClient()
20
        host_name = config_client.get_property('transaction_service_server_host')
21
        host_name = config_client.get_property('transaction_service_server_host')
21
        port = config_client.get_property('transaction_service_server_port')
22
        port = config_client.get_property('transaction_service_server_port')
22
        dbname = config_client.get_property('transaction_service_dbname')
23
        dbname = config_client.get_property('transaction_service_dbname')
-
 
24
        db_hostname = config_client.get_property('transaction_service_db_hostname')
23
    except:
25
    except:
24
        #error while spawning the config server
26
        #error while spawning the config server
25
        host_name = 'localhost'
27
        host_name = 'localhost'
26
        port = 9002
28
        port = 9002
27
        dbname = 'transaction'
29
        dbname = 'transaction'
-
 
30
        db_hostname='localhost'
28
        
31
        
29
    handler = OrderServiceHandler(dbname)
32
    handler = OrderServiceHandler(dbname, db_hostname)
30
    processor = TransactionService.Processor(handler)
33
    processor = TransactionService.Processor(handler)
31
    transport = TSocket.TServerSocket(port)
34
    transport = TSocket.TServerSocket(port)
32
    tfactory = TTransport.TFramedTransportFactory()
35
    tfactory = TTransport.TFramedTransportFactory()
33
    pfactory = TBinaryProtocolFactory()
36
    pfactory = TBinaryProtocolFactory()
34
    server = TServer.TThreadedServer(processor, transport, tfactory, pfactory)
37
    server = TServer.TThreadedServer(processor, transport, tfactory, pfactory)