diff options
| author | Jenkins <jenkins@review.openstack.org> | 2012-11-01 21:42:25 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2012-11-01 21:42:25 +0000 |
| commit | f43771cf1f83b0ded2e1ff3ba9a5960cdb7b48dd (patch) | |
| tree | c4218b52769f36908ac0c1e268b46a00d5365b96 /openstack | |
| parent | 4c00615aad0a21d81924586a7265f31a51801b30 (diff) | |
| parent | b7e697187cbc2cafd2e8dd810ab14746e0108e52 (diff) | |
| download | oslo-f43771cf1f83b0ded2e1ff3ba9a5960cdb7b48dd.tar.gz oslo-f43771cf1f83b0ded2e1ff3ba9a5960cdb7b48dd.tar.xz oslo-f43771cf1f83b0ded2e1ff3ba9a5960cdb7b48dd.zip | |
Merge "kombu's fanout_cast_to_server was calling wrong method"
Diffstat (limited to 'openstack')
| -rw-r--r-- | openstack/common/rpc/impl_kombu.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/openstack/common/rpc/impl_kombu.py b/openstack/common/rpc/impl_kombu.py index eccb7ab..f518c36 100644 --- a/openstack/common/rpc/impl_kombu.py +++ b/openstack/common/rpc/impl_kombu.py @@ -777,7 +777,7 @@ def cast_to_server(conf, context, server_params, topic, msg): def fanout_cast_to_server(conf, context, server_params, topic, msg): """Sends a message on a fanout exchange to a specific server.""" - return rpc_amqp.cast_to_server( + return rpc_amqp.fanout_cast_to_server( conf, context, server_params, topic, msg, rpc_amqp.get_connection_pool(conf, Connection)) |