| 398 | } |
| 399 | |
| 400 | returned<receiver> container::impl::open_receiver(const std::string &urlstr, const proton::receiver_options &o1, const connection_options &o2) { |
| 401 | proton::url url(urlstr); |
| 402 | pn_link_t* pnl = 0; |
| 403 | pn_connection_t* pnc = 0; |
| 404 | { |
| 405 | GUARD(lock_); |
| 406 | proton::receiver_options lopts(receiver_options_); |
| 407 | lopts.update(o1); |
| 408 | pnc = make_connection_lh(url, o2); |
| 409 | connection conn(make_wrapper(pnc)); |
| 410 | pnl = unwrap(conn.default_session().open_receiver(url.path(), lopts)); |
| 411 | } |
| 412 | start_connection(url, pnc); // See comment on start_connection |
| 413 | return make_returned<receiver>(pnl); |
| 414 | } |
| 415 | |
| 416 | pn_listener_t* container::impl::listen_common_lh(const std::string& addr) { |
| 417 | if (stopping_) |
nothing calls this directly
no test coverage detected