Skip to content
Snippets Groups Projects
Commit 33ebcaed authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

TMSS-190: no need (at this moment) to startup RADBPGListener. Saves startup time.

parent e6eb5ff5
No related branches found
No related tags found
1 merge request!252Resolve TMSS-190
...@@ -34,7 +34,6 @@ from lofar.sas.resourceassignment.database.testing.radb_common_testing import RA ...@@ -34,7 +34,6 @@ from lofar.sas.resourceassignment.database.testing.radb_common_testing import RA
from lofar.sas.resourceassignment.resourceassigner.raservice import RAService from lofar.sas.resourceassignment.resourceassigner.raservice import RAService
from lofar.sas.resourceassignment.resourceassignmentservice.service import createService as createRADBService from lofar.sas.resourceassignment.resourceassignmentservice.service import createService as createRADBService
from lofar.sas.resourceassignment.resourceassignmentestimator.service import createService as createEstimatorService from lofar.sas.resourceassignment.resourceassignmentestimator.service import createService as createEstimatorService
from lofar.sas.resourceassignment.database.radbpglistener import RADBPGListener
class RATestEnvironment: class RATestEnvironment:
'''Create and run a several ResourrceAssigner services in an isolated test environment''' '''Create and run a several ResourrceAssigner services in an isolated test environment'''
...@@ -45,21 +44,15 @@ class RATestEnvironment: ...@@ -45,21 +44,15 @@ class RATestEnvironment:
self.radb_service = createRADBService(dbcreds=self.radb_test_instance.dbcreds, exchange=exchange, broker=broker) self.radb_service = createRADBService(dbcreds=self.radb_test_instance.dbcreds, exchange=exchange, broker=broker)
self.re_service = createEstimatorService(exchange=exchange, broker=broker) self.re_service = createEstimatorService(exchange=exchange, broker=broker)
self.ra_service = RAService(radbcreds=self.radb_test_instance.dbcreds, exchange=exchange, broker=broker) self.ra_service = RAService(radbcreds=self.radb_test_instance.dbcreds, exchange=exchange, broker=broker)
self.radb_pg_listener = None
def start(self): def start(self):
self.radb_test_instance.create() self.radb_test_instance.create()
self.radb.connect() self.radb.connect()
self.radb_pg_listener = RADBPGListener(dbcreds=self.radb_test_instance.dbcreds,
exchange=self.radb_service.exchange,
broker=self.radb_service.broker)
self.radb_pg_listener.start()
self.radb_service.start_listening() self.radb_service.start_listening()
self.re_service.start_listening() self.re_service.start_listening()
self.ra_service.start_listening() self.ra_service.start_listening()
def stop(self): def stop(self):
self.radb_pg_listener.stop()
self.radb.disconnect() self.radb.disconnect()
self.ra_service.stop_listening() self.ra_service.stop_listening()
self.re_service.stop_listening() self.re_service.stop_listening()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment