From 73940f9c146d3ab284be494d21fffdca42195be9 Mon Sep 17 00:00:00 2001
From: Cristiano Urban <cristiano.urban@inaf.it>
Date: Thu, 20 May 2021 20:17:45 +0200
Subject: [PATCH] Minor changes,
Signed-off-by: Cristiano Urban <cristiano.urban@inaf.it>
---
transfer_service/config/vos_ts.conf | 7 -------
transfer_service/import_rpc_server.py | 6 ++++--
2 files changed, 4 insertions(+), 9 deletions(-)
diff --git a/transfer_service/config/vos_ts.conf b/transfer_service/config/vos_ts.conf
index dd8a388..4120241 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 c521bcf..219cf36 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,
--
GitLab