diff options
Diffstat (limited to 'ironic/conductor/rpcapi.py')
| -rw-r--r-- | ironic/conductor/rpcapi.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/ironic/conductor/rpcapi.py b/ironic/conductor/rpcapi.py index 16b66e637..65b234d16 100644 --- a/ironic/conductor/rpcapi.py +++ b/ironic/conductor/rpcapi.py @@ -202,6 +202,10 @@ class ConductorAPI(object): host = random.choice(list(ring.nodes)) return self.topic + "." + host + def get_current_topic(self): + """Get RPC topic name for the current conductor.""" + return self.topic + "." + CONF.host + def can_send_create_port(self): """Return whether the RPCAPI supports the create_port method.""" return self.client.can_send_version("1.41") |