SW-699: adaptations to new rpc.py module

LTA/LTAIngest/LTAIngestServer/LTAIngestAdminServer/lib/ingestmomadapter.py

@@ -49,7 +49,7 @@ class IngestEventMessageHandlerForMomAdapter(IngestEventMessageHandler):
         self.exchange = exchange
         self.broker = broker
         self._otdb_id2mom_id = {}
-        self._momrpc = MoMQueryRPC(exchange=exchange, broker=broker, timeout=180)
+        self._momrpc = MoMQueryRPC.create(exchange=exchange, broker=broker, timeout=180)
         self._mom_client = MoMClient(mom_creds.user, mom_creds.password)
         self._tobus = ToBus(exchange=exchange, broker=broker)
         self._removed_export_ids = set() # keep track of which export_id's were removed, so we don't have to remove them again
@@ -202,7 +202,7 @@ class IngestEventMessageHandlerForMomAdapter(IngestEventMessageHandler):
                             # this keeps stuff flowing faster
                             self._removed_export_ids.add(export_id)
 
-                            with IngestRPC(broker=self.broker) as ingest_rpc:
+                            with IngestRPC.create(exchange=self.exchange, broker=self.broker) as ingest_rpc:
                                 ingest_rpc.removeExportJob(export_id)
                                 return True
         return False