Merge pull request #202 from onefinestay/fix_keyboardinterrupt_race

make sure queue is still there
nameko · Feb 13, 2015 · 3ba2868 · 3ba2868
2 parents 633b614 + 1f4ee9b
commit 3ba2868
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/nameko/standalone/rpc.py b/nameko/standalone/rpc.py
@@ -139,6 +139,8 @@ def _poll_messages(self):
             except KeyboardInterrupt as exc:
                 event = self.provider._reply_events.pop(correlation_id)
                 event.send_exception(exc)
+                # exception may have killed the connection
+                self._setup_queue()
                 correlation_id = yield