Thread safe
| 72 | |
| 73 | // Thread safe |
| 74 | void send(const proton::message& msg) { |
| 75 | // Use [=] to copy the message, we cannot pass it by reference since it |
| 76 | // will be used in another thread. |
| 77 | work_queue()->add([=]() { sender_.send(msg); }); |
| 78 | } |
| 79 | |
| 80 | // Thread safe |
| 81 | proton::message receive() { |
no test coverage detected