Repository: qpid-proton Updated Branches: refs/heads/master de791d309 -> 7e3557c81
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/7e3557c8 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/7e3557c8 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/7e3557c8 Branch: refs/heads/master Commit: 7e3557c81bf3741f1040109412c2a49afece3a57 Parents: de791d3 Author: Clifford Jansen <[email protected]> Authored: Mon Jun 6 07:57:25 2016 -0700 Committer: Clifford Jansen <[email protected]> Committed: Mon Jun 6 07:57:25 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/7e3557c8/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]
