diff options
Diffstat (limited to 'python/qpid/session.py')
| -rw-r--r-- | python/qpid/session.py | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/python/qpid/session.py b/python/qpid/session.py index a77ef91c0f..d5b4a75b62 100644 --- a/python/qpid/session.py +++ b/python/qpid/session.py @@ -289,6 +289,16 @@ class Receiver: if seg.last: self._completed.add(seg.id) + def known_completed(self, commands): + completed = RangeSet() + for c in self._completed.ranges: + for kc in commands.ranges: + if c.lower in kc and c.upper in kc: + break + else: + completed.add_range(c) + self._completed = completed + class Sender: def __init__(self, session): |