Repository: qpid-proton Updated Branches: refs/heads/master aa548c40b -> f252261b9
PROTON-906: add DurableSubscription option utility Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/f252261b Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/f252261b Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/f252261b Branch: refs/heads/master Commit: f252261b971f9bcc64dc4c54de95f9429c5766bc Parents: aa548c4 Author: Gordon Sim <g...@redhat.com> Authored: Wed Jun 10 16:58:28 2015 +0100 Committer: Gordon Sim <g...@redhat.com> Committed: Wed Jun 10 16:58:28 2015 +0100 ---------------------------------------------------------------------- proton-c/bindings/python/proton/reactor.py | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/f252261b/proton-c/bindings/python/proton/reactor.py ---------------------------------------------------------------------- diff --git a/proton-c/bindings/python/proton/reactor.py b/proton-c/bindings/python/proton/reactor.py index 0145a25..a7b0717 100644 --- a/proton-c/bindings/python/proton/reactor.py +++ b/proton-c/bindings/python/proton/reactor.py @@ -411,6 +411,11 @@ class Selector(Filter): def __init__(self, value, name='selector'): super(Selector, self).__init__({symbol(name): Described(symbol('apache.org:selector-filter:string'), value)}) +class DurableSubscription(ReceiverOption): + def apply(self, receiver): + receiver.source.durability = Terminus.DELIVERIES + receiver.source.expiry_policy = Terminus.EXPIRE_NEVER + class Move(ReceiverOption): def apply(self, receiver): receiver.source.distribution_mode = Terminus.DIST_MODE_MOVE --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
