Minor changes,

Signed-off-by: Cristiano Urban <cristiano.urban@inaf.it>

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

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,6 +92,8 @@ class ImportRPCServer(RedisRPCServer):
                 jobObj.setOwnerId(userId)
                 self.dbConn.insertJob(jobObj)
                 self.importReadyQueue.insertJob(jobObj)
+                out.write(requestBody.copy())
+                out.close()
 
                 response = { "responseType": "IMPORT_STARTED" }
         else: