diff options
| author | Soren Hansen <soren@linux2go.dk> | 2011-02-10 14:56:24 +0100 |
|---|---|---|
| committer | Soren Hansen <soren@linux2go.dk> | 2011-02-10 14:56:24 +0100 |
| commit | 3f800a8ecde159cb34c5fe358da3aadce660a03a (patch) | |
| tree | 0b90d599979ed6e57635c67e60bdfb8df1d6734d /nova/rpc.py | |
| parent | 5e66cf492f150bfbd01e5983d876192c5b158343 (diff) | |
| download | nova-3f800a8ecde159cb34c5fe358da3aadce660a03a.tar.gz nova-3f800a8ecde159cb34c5fe358da3aadce660a03a.tar.xz nova-3f800a8ecde159cb34c5fe358da3aadce660a03a.zip | |
Make rpc.cast create a fresh amqp connection. Each API request has its own thread, and they don't multiplex well.
Diffstat (limited to 'nova/rpc.py')
| -rw-r--r-- | nova/rpc.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/nova/rpc.py b/nova/rpc.py index 01fc6d44b..c19ee4635 100644 --- a/nova/rpc.py +++ b/nova/rpc.py @@ -346,7 +346,7 @@ def cast(context, topic, msg): """Sends a message on a topic without waiting for a response""" LOG.debug(_("Making asynchronous cast...")) _pack_context(msg, context) - conn = Connection.instance() + conn = Connection.instance(True) publisher = TopicPublisher(connection=conn, topic=topic) publisher.send(msg) publisher.close() |