diff --git a/transfer_service/storage_amqp_server.py b/transfer_service/storage_amqp_server.py index 1ed035673b95d712f33aeacafb732e936ac798af..1cad1315ea2945e45e96bb6d4f7096358de5c610 100644 --- a/transfer_service/storage_amqp_server.py +++ b/transfer_service/storage_amqp_server.py @@ -53,8 +53,15 @@ class StorageAMQPServer(AMQPServer): return response elif requestBody["requestType"] == "STORAGE_RMV": pass - elif requestBody["requestType"] == "STORAGE_LST": - pass + elif requestBody["requestType"] == "STORAGE_LST": + self.dbConn.connect() + result = self.dbConn.getStorageList() + self.dbConn.disconnect() + + response = { "responseType": "STORAGE_LST_DONE", + "storageList": result } + + return response def run(self): print(f"Starting AMQP server of type {self.type}...")