diff options
| author | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-09-02 20:47:51 +0000 |
|---|---|---|
| committer | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-09-02 20:47:51 +0000 |
| commit | e235d7731399a908e3acb11c3d85eaa699031c6b (patch) | |
| tree | 03385f7637cdf6cbcfa6053f48c59951ed8800f1 | |
| parent | fb24102a112fc7f93d7f3e26f76251a6e04645a3 (diff) | |
| download | qpid-python-e235d7731399a908e3acb11c3d85eaa699031c6b.tar.gz | |
QPID-2846: release pending sequence numbers when cleaning up an agent.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@992113 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/extras/qmf/src/py/qmf/console.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/qpid/extras/qmf/src/py/qmf/console.py b/qpid/extras/qmf/src/py/qmf/console.py index 79e74d6198..80684de0d3 100644 --- a/qpid/extras/qmf/src/py/qmf/console.py +++ b/qpid/extras/qmf/src/py/qmf/console.py @@ -2945,6 +2945,7 @@ class Agent: for seq in copy: context = copy[seq] context.cancel("Agent disconnected") + self.seqMgr._release(seq) def __repr__(self): @@ -3052,7 +3053,10 @@ class Agent: def _clearContext(self, sequence): try: self.lock.acquire() - self.contextMap.pop(sequence) + try: + self.contextMap.pop(sequence) + except KeyError: + pass # @todo - shouldn't happen, log a warning. finally: self.lock.release() |