Repository: qpid-proton Updated Branches: refs/heads/0.13.x 662592386 -> 097222977
PROTON-1226: set handler directly on inbound connection configuration Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/09722297 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/09722297 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/09722297 Branch: refs/heads/0.13.x Commit: 09722297710186d1ae5de3e4621e3f2fa08644c6 Parents: 6625923 Author: Clifford Jansen <[email protected]> Authored: Mon Jun 6 07:47:32 2016 -0700 Committer: Clifford Jansen <[email protected]> Committed: Mon Jun 6 07:47:32 2016 -0700 ---------------------------------------------------------------------- proton-c/bindings/cpp/src/container_impl.cpp | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/09722297/proton-c/bindings/cpp/src/container_impl.cpp ---------------------------------------------------------------------- diff --git a/proton-c/bindings/cpp/src/container_impl.cpp b/proton-c/bindings/cpp/src/container_impl.cpp index ca12727..ce6a2b2 100644 --- a/proton-c/bindings/cpp/src/container_impl.cpp +++ b/proton-c/bindings/cpp/src/container_impl.cpp @@ -253,6 +253,13 @@ void container_impl::configure_server_connection(connection &c) { connection_options opts = server_connection_options_; opts.update(lc.get_options()); opts.apply(c); + // Handler applied separately + proton_handler *h = opts.handler(); + if (h) { + internal::pn_ptr<pn_handler_t> chandler = cpp_handler(h); + pn_record_t *record = pn_connection_attachments(unwrap(c)); + pn_record_set_handler(record, chandler.get()); + } } void container_impl::run() { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
