Commit 666e6f38 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Added getint() method for AMQP port obtained from the config file. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban@inaf.it>
parent a720c864

transfer_service/transfer_service.py

+2 −2
Original line number Diff line number Diff line
@@ -11,7 +11,7 @@ class TransferService(object): 
    def __init__(self):

        config = Config("vos_ts.conf")

        self.params = config.loadSection("amqp")

        self.jobHandler = JobHandler(self.params["host"], self.params["port"])

        self.jobHandler = JobHandler(self.params["host"], self.params.getint("port"))

        self.storePreprocessor = StorePreprocessor()



        # PullFromVOSpace (via REST API)
@@ -19,7 +19,7 @@ class TransferService(object): 
        self.jobHandler.addAMQPServer('poll', 'poll_job_queue')

        self.jobHandler.addAMQPServer('abort', 'abort_job_queue')



        # PushToVOSpace (via dataArchiver 'unofficial' command line client)

        # PushToVOSpace (via dataArchiver, the 'unofficial' command line client)

        self.jobHandler.addAMQPServer('store', 'store_job_queue')        



    def start(self):