diff options
| author | Chris Behrens <cbehrens@codestud.com> | 2011-05-25 15:42:24 -0700 |
|---|---|---|
| committer | termie <github@anarkystic.com> | 2011-05-25 15:42:24 -0700 |
| commit | d0be426d4e7bbfb1ecb3f078c71c1e176da441a5 (patch) | |
| tree | c31b01c133ab53bedcfa19e22132a3c190abf5a1 | |
| parent | e1a47584cc63136280cf3ca9ef02da3efc1dff7f (diff) | |
| download | nova-d0be426d4e7bbfb1ecb3f078c71c1e176da441a5.tar.gz nova-d0be426d4e7bbfb1ecb3f078c71c1e176da441a5.tar.xz nova-d0be426d4e7bbfb1ecb3f078c71c1e176da441a5.zip | |
convert fanout_cast to ConnectionPool
| -rw-r--r-- | nova/rpc.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/nova/rpc.py b/nova/rpc.py index db5aec826..fdb228695 100644 --- a/nova/rpc.py +++ b/nova/rpc.py @@ -526,10 +526,11 @@ def fanout_cast(context, topic, msg): """Sends a message on a fanout exchange without waiting for a response.""" LOG.debug(_('Making asynchronous fanout cast...')) _pack_context(msg, context) - conn = Connection.instance() + conn = ConnectionPool.get() publisher = FanoutPublisher(topic, connection=conn) publisher.send(msg) publisher.close() + ConnectionPool.put(conn) def generic_response(message_data, message): |