You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2015/06/10 17:56:21 UTC
qpid-proton git commit: PROTON-906: add DurableSubscription option
utility
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 <gs...@redhat.com>
Authored: Wed Jun 10 16:58:28 2015 +0100
Committer: Gordon Sim <gs...@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-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org