| 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 | |
| 288 | class QueueManager { |
nothing calls this directly
no test coverage detected