MCPcopy Create free account
hub / github.com/apache/qpid-proton / on_sender_open

Method on_sender_open

cpp/examples/multithreaded_client.cpp:118–124  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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_);

Callers

nothing calls this directly

Calls 1

work_queueMethod · 0.45

Tested by

no test coverage detected