| 116 | } |
| 117 | |
| 118 | void on_sender_open(proton::sender& s) override { |
| 119 | // sender_ and work_queue_ must be set atomically |
| 120 | std::lock_guard<std::mutex> l(lock_); |
| 121 | sender_ = s; |
| 122 | work_queue_ = &s.work_queue(); |
| 123 | sender_ready_.notify_all(); |
| 124 | } |
| 125 | |
| 126 | void on_message(proton::delivery& dlv, proton::message& msg) override { |
| 127 | std::lock_guard<std::mutex> l(lock_); |
nothing calls this directly
no test coverage detected