diff --git a/SAS/ResourceAssignment/ResourceAssigner/test/ra_test_environment.py b/SAS/ResourceAssignment/ResourceAssigner/test/ra_test_environment.py
index 7889f0153a13cf5e5ddf54afaf755f9c3fa2f30e..5046b4eb97f63c4354418a1352c9e4803c641054 100644
--- a/SAS/ResourceAssignment/ResourceAssigner/test/ra_test_environment.py
+++ b/SAS/ResourceAssignment/ResourceAssigner/test/ra_test_environment.py
@@ -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.resourceassignmentservice.service import createService as createRADBService
 from lofar.sas.resourceassignment.resourceassignmentestimator.service import createService as createEstimatorService
-from lofar.sas.resourceassignment.database.radbpglistener import RADBPGListener
 
 class RATestEnvironment:
     '''Create and run a several ResourrceAssigner services in an isolated test environment'''
@@ -45,21 +44,15 @@ class RATestEnvironment:
         self.radb_service = createRADBService(dbcreds=self.radb_test_instance.dbcreds, 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.radb_pg_listener = None
 
     def start(self):
         self.radb_test_instance.create()
         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.re_service.start_listening()
         self.ra_service.start_listening()
 
     def stop(self):
-        self.radb_pg_listener.stop()
         self.radb.disconnect()
         self.ra_service.stop_listening()
         self.re_service.stop_listening()