|
@@ -371,6 +371,14 @@ class BaseComponent:
|
|
"""
|
|
"""
|
|
pass
|
|
pass
|
|
|
|
|
|
|
|
+ def address(self):
|
|
|
|
+ """
|
|
|
|
+ Provides the name of the address used on the message bus
|
|
|
|
+
|
|
|
|
+ You need to provide this method in a concrete implementation.
|
|
|
|
+ """
|
|
|
|
+ pass
|
|
|
|
+
|
|
class Component(BaseComponent):
|
|
class Component(BaseComponent):
|
|
"""
|
|
"""
|
|
The most common implementation of a component. It can be used either
|
|
The most common implementation of a component. It can be used either
|
|
@@ -454,6 +462,12 @@ class Component(BaseComponent):
|
|
else:
|
|
else:
|
|
self._procinfo.process.terminate()
|
|
self._procinfo.process.terminate()
|
|
|
|
|
|
|
|
+ def address(self):
|
|
|
|
+ """
|
|
|
|
+ Returns the name of the address used on the message bus
|
|
|
|
+ """
|
|
|
|
+ return self._address
|
|
|
|
+
|
|
class Configurator:
|
|
class Configurator:
|
|
"""
|
|
"""
|
|
This thing keeps track of configuration changes and starts and stops
|
|
This thing keeps track of configuration changes and starts and stops
|