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

Method unsubscribe

cpp/examples/broker.cpp:183–189  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

181 subscriptions_[s] = 0;
182 }
183 void unsubscribe(Sender* s) {
184 DOUT(std::cerr << "Queue: " << this << "(" << name_ << ") unsubscribe Sender: " << s << "\n";);
185 // If we're about to erase the current subscription move on
186 if (current_ != subscriptions_.end() && current_->first==s) ++current_;
187 subscriptions_.erase(s);
188 s->add([=]{s->unsubscribed();});
189 }
190};
191
192// We have credit to send a message.

Callers 3

on_sender_closeMethod · 0.45
on_session_closeMethod · 0.45
on_transport_closeMethod · 0.45

Calls 4

eraseMethod · 0.80
unsubscribedMethod · 0.80
endMethod · 0.45
addMethod · 0.45

Tested by

no test coverage detected