| 66 | } |
| 67 | |
| 68 | void on_message(proton::delivery &d, proton::message &response) override { |
| 69 | if (requests.empty()) return; // Spurious extra message! |
| 70 | |
| 71 | std::cout << requests.front() << " => " << response.body() << std::endl; |
| 72 | requests.erase(requests.begin()); |
| 73 | |
| 74 | if (!requests.empty()) { |
| 75 | send_request(); |
| 76 | } else { |
| 77 | d.connection().close(); |
| 78 | } |
| 79 | } |
| 80 | }; |
| 81 | |
| 82 | int main(int argc, char **argv) { |