PROTON-1517: For broader compatibility, use a string correlation ID
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/2b033949 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/2b033949 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/2b033949 Branch: refs/heads/go1 Commit: 2b033949c54549591113e61ea33e625f9b898cbb Parents: e22ca53 Author: Justin Ross <[email protected]> Authored: Fri Dec 8 13:03:07 2017 -0800 Committer: Justin Ross <[email protected]> Committed: Fri Dec 8 13:03:07 2017 -0800 ---------------------------------------------------------------------- proton-c/bindings/python/proton/utils.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/2b033949/proton-c/bindings/python/proton/utils.py ---------------------------------------------------------------------- diff --git a/proton-c/bindings/python/proton/utils.py b/proton-c/bindings/python/proton/utils.py index cf36bbe..1d052d0 100644 --- a/proton-c/bindings/python/proton/utils.py +++ b/proton-c/bindings/python/proton/utils.py @@ -372,7 +372,7 @@ class SyncRequestResponse(IncomingMessageHandler): if not self.address and not request.address: raise ValueError("Request message has no address: %s" % request) request.reply_to = self.reply_to - request.correlation_id = correlation_id = self.correlation_id.next() + request.correlation_id = correlation_id = str(self.correlation_id.next()) self.sender.send(request) def wakeup(): return self.response and (self.response.correlation_id == correlation_id) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
