diff options
Diffstat (limited to 'qpid/cpp/bindings')
| -rw-r--r-- | qpid/cpp/bindings/qpid/python/qpid_messaging.i | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/qpid/cpp/bindings/qpid/python/qpid_messaging.i b/qpid/cpp/bindings/qpid/python/qpid_messaging.i index f31b734efa..513cc531ae 100644 --- a/qpid/cpp/bindings/qpid/python/qpid_messaging.i +++ b/qpid/cpp/bindings/qpid/python/qpid_messaging.i @@ -151,6 +151,7 @@ QPID_EXCEPTION(UnauthorizedAccess, SessionError) %rename(_next_receiver) qpid::messaging::Session::nextReceiver; %rename(_fetch) qpid::messaging::Receiver::fetch; +%rename(_get) qpid::messaging::Receiver::get; %rename(unsettled) qpid::messaging::Receiver::getUnsettled; %rename(available) qpid::messaging::Receiver::getAvailable; @@ -346,6 +347,16 @@ QPID_EXCEPTION(UnauthorizedAccess, SessionError) # but C++ API uses milliseconds return self._fetch(Duration(int(1000*timeout))) %} + + %pythoncode %{ + def get(self, timeout=None) : + if timeout is None : + return self._get() + else : + # Python API uses timeouts in seconds, + # but C++ API uses milliseconds + return self._get(Duration(int(1000*timeout))) + %} } %extend qpid::messaging::Sender { |