| 381 | } |
| 382 | |
| 383 | returned<sender> container::impl::open_sender(const std::string &urlstr, const proton::sender_options &o1, const connection_options &o2) |
| 384 | { |
| 385 | proton::url url(urlstr); |
| 386 | pn_link_t* pnl = 0; |
| 387 | pn_connection_t* pnc = 0; |
| 388 | { |
| 389 | GUARD(lock_); |
| 390 | proton::sender_options lopts(sender_options_); |
| 391 | lopts.update(o1); |
| 392 | pnc = make_connection_lh(url, o2); |
| 393 | connection conn(make_wrapper(pnc)); |
| 394 | pnl = unwrap(conn.default_session().open_sender(url.path(), lopts)); |
| 395 | } |
| 396 | start_connection(url, pnc); // See comment on start_connection |
| 397 | return make_returned<sender>(pnl); // Unsafe returned pointer |
| 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); |
nothing calls this directly
no test coverage detected