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

Method boundQueue

cpp/examples/broker.cpp:276–285  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

274 }
275
276 void boundQueue(Queue* q, std::string qn) {
277 DOUT(std::cerr << "Receiver: " << this << " bound to Queue: " << q << "(" << qn << ")\n";);
278 queue_ = q;
279 receiver_.open(proton::receiver_options()
280 .source((proton::source_options().address(qn)))
281 .handler(*this));
282 std::cout << "receiving to " << qn << std::endl;
283
284 queueMsgs();
285 }
286};
287
288class QueueManager {

Callers

nothing calls this directly

Calls 6

receiver_optionsClass · 0.50
source_optionsClass · 0.50
openMethod · 0.45
handlerMethod · 0.45
sourceMethod · 0.45
addressMethod · 0.45

Tested by

no test coverage detected