diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-02-08 15:58:59 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-02-08 15:58:59 +0000 |
| commit | dbb4061563e552266d6b6d0793a94135cb25ca73 (patch) | |
| tree | c25460444d9da6bbe8d6032ea8adc6f2cde84593 /openstack/common/rpc | |
| parent | 0e4514a5596e71afbdf60a5329e8c2d141a344fc (diff) | |
| parent | 9fd64373fd07ac63e2674374054160d3bead54b7 (diff) | |
| download | oslo-dbb4061563e552266d6b6d0793a94135cb25ca73.tar.gz oslo-dbb4061563e552266d6b6d0793a94135cb25ca73.tar.xz oslo-dbb4061563e552266d6b6d0793a94135cb25ca73.zip | |
Merge "Exchanges should return directed topics."
Diffstat (limited to 'openstack/common/rpc')
| -rw-r--r-- | openstack/common/rpc/matchmaker.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/openstack/common/rpc/matchmaker.py b/openstack/common/rpc/matchmaker.py index 48270ba..d68799b 100644 --- a/openstack/common/rpc/matchmaker.py +++ b/openstack/common/rpc/matchmaker.py @@ -211,14 +211,14 @@ class LocalhostExchange(Exchange): class DirectExchange(Exchange): """ Exchange where all topic keys are split, sending to second half. - i.e. "compute.host" sends a message to "compute" running on "host" + i.e. "compute.host" sends a message to "compute.host" running on "host" """ def __init__(self): super(Exchange, self).__init__() def run(self, key): - b, e = key.split('.', 1) - return [(b, e)] + e = key.split('.', 1)[1] + return [(key, e)] class MatchMakerRing(MatchMakerBase): |