diff --git a/transfer_service/config/vos_ts.conf b/transfer_service/config/vos_ts.conf index dd8a3884faae5787bb1c9e4d15e5ede843cd06a6..41202415c706148fba67a7888215ccedde74d257 100644 --- a/transfer_service/config/vos_ts.conf +++ b/transfer_service/config/vos_ts.conf @@ -24,13 +24,6 @@ port = 6379 ; db index representing the db that stores the scheduling queues, default is 0 db_sched = 0 -# RabbitMQ -[amqp] -; hostname or IP address of the machine that hosts the RabbitMQ message broker -host = rabbitmq -; port at which the broker is available, default is 5672 TCP -port = 5672 - # Spectrum Archive [spectrum_archive] ; hostname or IP address of the tape library frontend diff --git a/transfer_service/import_rpc_server.py b/transfer_service/import_rpc_server.py index c521bcfeafa648b87d494d0ea079f432f59f6def..219cf36627c4fe9f9f101ee10c6dda6b55f6793b 100644 --- a/transfer_service/import_rpc_server.py +++ b/transfer_service/import_rpc_server.py @@ -40,7 +40,7 @@ class ImportRPCServer(RedisRPCServer): username = requestBody["userName"] userInDb = self.dbConn.userExists(username) userInfo = self.systemUtils.userInfo(username) - #out = open("import_amqp_server_log.txt", "a") + out = open("import_amqp_server_log.txt", "a") if not userInfo or not userInDb: response = { "responseType": "ERROR", @@ -92,8 +92,10 @@ class ImportRPCServer(RedisRPCServer): jobObj.setOwnerId(userId) self.dbConn.insertJob(jobObj) self.importReadyQueue.insertJob(jobObj) + out.write(requestBody.copy()) + out.close() - response = { "responseType": "IMPORT_STARTED" } + response = { "responseType": "IMPORT_STARTED" } else: response = { "responseType": "ERROR", "errorCode": 9,