diff options
| author | Chris Behrens <cbehrens@codestud.com> | 2012-11-01 19:45:07 +0000 |
|---|---|---|
| committer | Chris Behrens <cbehrens@codestud.com> | 2012-11-01 19:45:47 +0000 |
| commit | b7e697187cbc2cafd2e8dd810ab14746e0108e52 (patch) | |
| tree | 9fd1516389773d520fb3107793ddaa1469447ea1 /openstack | |
| parent | 3d6c2368a5de16d875341426db8ddc9888213264 (diff) | |
| download | oslo-b7e697187cbc2cafd2e8dd810ab14746e0108e52.tar.gz oslo-b7e697187cbc2cafd2e8dd810ab14746e0108e52.tar.xz oslo-b7e697187cbc2cafd2e8dd810ab14746e0108e52.zip | |
kombu's fanout_cast_to_server was calling wrong method
Make it call the common amqp method fanout_cast_to_server vs
cast_to_server.
Fixes bug 1074113
Change-Id: If06bde93dab94c6030465a5e7ba329d8936c69e3
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)) |