| 224 | } |
| 225 | |
| 226 | void on_connection_open(proton::connection &c) override { |
| 227 | if (c.active()) { |
| 228 | // outbound connection |
| 229 | c.open_receiver("flow_example", proton::receiver_options().handler(receive_handler).credit_window(0)); |
| 230 | } |
| 231 | } |
| 232 | |
| 233 | void on_connection_close(proton::connection &) override { |
| 234 | listener.stop(); |
nothing calls this directly
no test coverage detected