diff --git a/LCS/Messaging/python/messaging/test/t_RPC.py b/LCS/Messaging/python/messaging/test/t_RPC.py index 51eb067fa7167408ed23347261f53dd5e1d2ab0a..b81ddd978ae1183f3a624e1427612325458ffb06 100644 --- a/LCS/Messaging/python/messaging/test/t_RPC.py +++ b/LCS/Messaging/python/messaging/test/t_RPC.py @@ -34,6 +34,20 @@ class MyServiceMessageHandler(ServiceMessageHandler): def my_public_slow_method(self): sleep(2) + +class RPCServiceTests(unittest.TestCase): + def test_designated_queue_name_contains_subclass_name(self): + class MyService(RPCService): + pass + + with TemporaryExchange(self.__class__.__name__) as tmp_exchange: + service = MyService("my service", MyServiceMessageHandler, exchange=tmp_exchange.address) + queue_name = service.designated_queue_name() + + self.assertTrue(".MyService." in queue_name) + self.assertFalse(".BusListener." in queue_name) + + class TestRPC(unittest.TestCase): def test_registered_service_methods(self): handler = MyServiceMessageHandler("foo", "bar")