| 134 | |
| 135 | class tester_base: public proton::messaging_handler { |
| 136 | void on_connection_open(proton::connection& c) override { |
| 137 | std::string want_url = "amqp://localhost:" + std::to_string(listening_port_); |
| 138 | |
| 139 | if (!c.reconnected()) { |
| 140 | start_count++; |
| 141 | c.open_sender("messages"); |
| 142 | } |
| 143 | ASSERT_EQUAL(c.url(), want_url); |
| 144 | ASSERT_EQUAL(bool(open_count), c.reconnected()); |
| 145 | open_count++; |
| 146 | } |
| 147 | |
| 148 | void on_connection_error(proton::connection& c) override { |
| 149 | connection_error_count++; |
nothing calls this directly
no test coverage detected